java - Spring 集成 - 在流之间传递数据

标签 java spring spring-integration spring-integration-dsl

我有一个特殊的 IntegrationFlow 配置如下

@Bean
public IntegrationFlow setupRabbitFlow() {
    return IntegrationFlows.from(myInputChannel)     
            .handle((p, h) -> rabbitPublisher.publishToRabbit(p, h))
            .get();
}

以及处理来自某些 XML 文件的传入数据的其他流程,例如如此处所示Polling from file using Java DSL - compile error when adding Files.inboundAdapter 。在该流程结束时,我想将消息传递给上述兔子发送“接收器”。我如何声明这一点?

最佳答案

Spring Integration 中的一等公民之一是 MessageChannel抽象。

Spring Integration 组件(端点)之间的任何交互实际上都是通过消息 channel 完成的。

您需要从第二个流程中获得的内容只需在该流程的末尾指定 .channel(myInputChannel) 即可。 XML 处理的结果将发送到您的第一个流程。

关于java - Spring 集成 - 在流之间传递数据,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44653233/

相关文章:

java - 按钮未启用?

java - 动态添加的 View 不适合 Pane

java - Spring集成(5.0)-文件适配器: Enabling prevent-duplicates in custom scanner is not working

java - Spring集成DSL : how to make single-threaded caching channel?

java - 如何从ResourceBundle切换到Properties(类)?

Java HashMap 无法从 ListDataListener 事件中找到键

spring - 在 Spring Security OAuth2(提供者)中使用作用域作为角色

java - 如何在 jsp View 中加载 extjs 5 应用程序 - Spring MVC?

java - Spring MVC HTTP 错误 500 : Servlet. init() 的 servlet 通知抛出异常

java - Spring Integration,如何更好地描述验证组件