从spring-xd向gemfire发送自定义对象

Question

您好，我有一个问题，写一个对象，我定义了从sprin-xd到gemfire。

如果部署我的类，且如果我向gemfire控制台写入以下命令，我可以在包含Employee类的对象的region中创建新条目。

​

put --key-class=java.lang.String --value-class=Employee --key=('id':'998') --value=('id':186,'firstName':'James','lastName':'Goslinga') --region=replicated2

​

我想要做的是从spring-xd发送数据。我将在Gemfire中创建一个新的Employee类对象。

如果我创建这样的流，它将从rabbit获取数据并将其发送到gemfire。

​

stream create --name reference-data-import --definition "rabbit --outputType=text/plain | gemfire-json-server --host=MC0WJ1BC --regionName=region10 --keyExpression=payload.getField('id')" --deploy

​

我可以在这种类型的"com.gemstone.gemfire.pdx.internal.PdxInstanceImpl".中看到数据

关于spring-xd文档，我可以使用这样的参数outputType=application/x-java-object;type=com.bar.Foo，但即使我部署了我的类，我也从未设法解决它。如果我能看到一个简单的工作示例，那对我来说就太好了。

Answer 1

Spring XD没有提供从一种对象类型自动转换到另一种对象类型的工具，因为没有以自动方式处理映射的简单方法。相反，您需要在转换为com.bar.Foo对象的gemfire-server接收器之前创建一个转换器。从那里，它将被正确地序列化到Gemfire中。