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

Question

我有一个特殊的 IntegrationFlow 配置为

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

和其他一些处理来自某些 XML 文件的传入数据的流程，例如如此处所示 。在该流程结束时，我想将 Message 传递给上述发送兔子 "sink"。我该如何申报？

Answer 1

Spring 集成中的首批 class 公民之一是 MessageChannel 抽象。

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

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