如何解决无论如何,有没有要调整Feed Adapter以根据事件进行操作?
场景:-假设有一个消息通道正在接收来自任何流的消息,并且如果该通道接收到任何消息,那么feed适配器应该拉动feed(一次)并将这些feed发布到其他通道。之后,该Feed适配器应停止运行。有没有可能实现这一目标?
解决方法
FeedEntryMessageSource
基于:
Reader reader = this.feedUrl != null
? new XmlReader(this.feedUrl)
: new XmlReader(this.feedResource.getInputStream());
SyndFeed feed = this.syndFeedInput.build(reader);
来自com.rometools:rome
库的。因此,您可以以此构建一个自定义服务激活器,该事件将通过该事件在其输入通道上的消息激活。
为了更好地理解提要解析逻辑,我建议看一下FeedEntryMessageSource
源代码:https://github.com/spring-projects/spring-integration/blob/master/spring-integration-feed/src/main/java/org/springframework/integration/feed/inbound/FeedEntryMessageSource.java
更新
好吧,另一种方法就是将FeedEntryMessageSource
作为bean并从服务激活器中引用其receive()
方法。这样,当消息到达该服务激活器的输入通道时,它将按需调用,而完全忽略消息内容。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。