java - Spring 集成: receive messages from multiple JMS destinations

Question

我正在使用 java DSL 来配置我的 channel 适配器。我想要实现的事情可以用下面的代码来描述:

IntegrationFlows
                .from(Jms.messageDriverChannelAdapter(mqCacheConnectionFactory)
                        .configureListenerContainer(container -> container.sessionTransacted(transacted))
                        .destinations(inputDestination1, inputDestination2) // missing method
                        .autoStartup(autoStartup)
                        .id(channelName)
                        .errorChannel(errorChannel)
                )
                .channel(commonChannel)
                .get();

所以我希望有一个能够从多个 JMS 目的地接收消息的 messageDriverChannelAdapter 。可以实现吗？

Answer 1

不，这是不可能的。

Spring Integration JMS 支持完全基于 Spring JMS 基础。它的 AbstractMessageListenerContainer 提供了仅使用一个目的地的能力。因此，Jms.messageDriverChannelAdapter() 不提供配置多个监听目标的选项。

您唯一的选择是配置多个Jms.messageDriverChannelAdapter()。 Spring Integration 的好处是您可以将它们全部输出到同一个 MessageChannel 并且您不会有那么多的复制/粘贴 hell 。