0

我有一个自定义 Spring XD 源模块，它使用 Spring Social for Twitter 并输出 Tweet 对象。这工作得很好。我可以记录源的输出并查看列出的 Tweet 对象。我可以将该流的源的输出类型更改为 application/json 以查看 JSON 的输出。这按预期工作。

然后我创建了一个处理器模块，它将从该推文创建一个新对象并输出它。转换消息需要一个包含 Tweet 对象的 GenericMessage 作为其有效负载（我也尝试让方法参数只是 Tweet，但这也不起作用）。

@Transformer
public OtherThing<Tweet> transform(GenericMessage<Tweet> message) {
    // ... snip ...
}

但是，当我将两个模块链接在一起时

stream create --name test --definition 'my-tweet-source-module | my-tweet-processor | log' --deploy

并且从源模块输出一条推文，我得到一个类转换异常：

java.lang.ClassCastException: org.springframework.social.twitter.api.Tweet cannot be cast to org.springframework.social.twitter.api.Tweet

我已经验证这两个模块都使用相同版本的 Spring Social Twitter，所以那里应该没有问题。目前，模块通过本地传输进行通信，因此这也不应该是任何类加载问题（它们最终将需要通过非本地传输进行通信）。

我也尝试过解决方法，例如在流中定义源模块的输出类型应该是application/json，然后尝试从输入字符串有效负载中读取 JSON，但由于 Spring Social Tweet 对象的性质，Jackson 不遵守.

我想知道为什么会发生这种情况以及我应该如何解决这个问题？我觉得我无疑做错了什么。如果我不允许这样做，我想知道为什么会这样以及应该做的事情是什么。

任何帮助，将不胜感激。

谢谢

编辑：我正在使用 Spring XD 1.2.1.RELEASE

4

1 回答 1

3

投射到同一个类时，请参阅ClassCastException 。这几乎可以肯定是类加载器问题。尝试从模块的类路径中删除 spring-social 并将其添加到 xd/lib 以便它由同一个类加载器加载。

于 2015-09-13T13:09:46.197 回答