使用 spring-集成 java dsl .publishSubscribeChannel() 或 channel()？

Question

我想定义一个流程，例如"do operation A and then execute both B and C on the output payload of A":

       +- [B]
[A] -> |
       +- [C]

[B]和[C]执行后我真的不需要聚合

哪个是正确的？

使用 .publish("mychannel") 终止 [A] 并使用 IntegrationFlows.from("mychannel") 定义 [B] 和 [C] integrationFlows @Bean。 ..get()
用 .publishSubscribeChannel(...) 终止 [A]

Answer 1

我会说最适合您的设计必须看起来像 XML 配置：

@Bean
IntegrationFlow flowA() {
   return IntegrationFlow.from(...)
                      .channel("publishSubscribeChannel")
                      .get();
}

@Bean 
MessageChannel publishSubscribeChannel() {
   return new PublishSubscribeChannel();
}

@Bean
IntegrationFlow flowB() {
   return IntegrationFlow.from("publishSubscribeChannel")
           ...
}

@Bean
IntegrationFlow flowC() {
   return IntegrationFlow.from("publishSubscribeChannel")
           ...
}

只是因为您是这里的新手，对这里的许多功能还不满意。

P.S。请尊重我们的时间，允许我们做自己的工作，也许可以帮助其他人。我们无意为您工作——这是我们的责任。问题 "how does it work?" 或 "Seems for me it is a bug" 是讨论的好候选。但是类似 "what is your opinion about my design?"（或者像你的复杂样本的 JIRA）对于社区来说并不是那么有用。对不起。

使用 spring-集成 java dsl .publishSubscribeChannel() 或 channel()？

Using spring-integration java dsl .publishSubscribeChannel() or channel()?

spring-integration