如何根据配置动态创建多个jms消息驱动的通道适配器

Question

这是我的要求，需要配置超过 50 个入站消费者来监听不同的队列。

spring 集成中是否有任何选项，我可以从配置中传递我的队列详细信息，并且应该创建相应的消费者 bean 并将其添加到我的应用程序上下文中。

在此期间，我使用 java 8 和 spring 4.3.4

感谢任何帮助！

Answer 1

为此，我们实现了Dynamic Flows Registration。

我知道您可能不使用 Spring Integration Java DSL，但是没有一种简单的方法可以在运行时注册 bean。

IntegrationFlowContext 也可用于 Spring Integration 4.3.x：您需要包含 Spring Integration Java DSL 的扩展：https://github.com/spring-projects/spring-integration-java-dsl/

这样你就可以在代码中做这样的事情：

 IntegrationFlow flow = f -> 
          IntegrationFlows.from(
               Jms.messageDriverChannelAdapter(this.connectionFactory)
                    .destination(aDestinationName))
                 .channel(channelToSend)
                 get();

    IntegrationFlowRegistration theFlow = this.flowContext.registration(flow).register();