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

Question

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

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

以及处理来自某些 XML 文件的传入数据的其他一些流程，例如此处所示Polling from file using Java DSL - 添加 Files.inboundAdapter 时出现编译错误。在该流程结束时，我想将 Message 传递给上述发送兔子的“接收器”。我该如何声明？

Answer 1

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

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

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