Spring Integration Java DSL-IntegrationFlow多个订户

Question

我对Spring Integration DSL的使用速度太快了。我在玩下面的例子。

 @Bean
    public IntegrationFlow flow() {
        return IntegrationFlows.from(INBOX)
                .transform(p -> "world")
                .get();
    }

我正在寻找从这一个流订阅多个频道的能力。我找不到任何关于这个的东西。

例如，下面这样的内容，其中该流被订阅到不同的频道。

 @Bean
        public IntegrationFlow flow() {
            return IntegrationFlows.from(INBOX).flow(INBOX2)
                    .transform(p -> "world")
                    .get();
        }

Answer 1

在本教程中[使用Spring Integration Java DSL在一个事务中接收和发送多个JMS消息]，他们这样描述

但是，Java DSL尚未提供此属性。解决这个问题的另一种方法是用事务轮询器替换消息驱动的通道适配器，但是在当前的JavaDSL中这也是不可能的。为了解决这个问题，我们将出站适配器中的jmsFactory替换为会话事务设置为true的jmsTemplate。导致：

IntegrationFlows
  .from(subscribableChannel())
  .handle(Jms.outboundAdapter(jmsTemplate).destination(QUEUE2))
.get();

Answer 2

这是不可能的。没有任何带有多个输入通道的endpoint。

另一方面，我们不需要这样的复杂性，因为我们总是可以将从一个通道连接到另一个通道：

@Bean
@BridgeTo(INBOX)
public MessageChannel INBOX2() {
    return new DirectChannel();
}

你也可以考虑使用一些<代码>路由器>代码>来评估所需的输出通道。

在Spring集成设计中，MessageChannel本身很复杂，弄乱endpoint逻辑听起来不太好。