Как динамически создать адаптер канала с несколькими jms-сообщениями на основе конфигурации

Question

Вот мое требование, для которого необходимо настроить более 50 входящих клиентов для прослушивания различных очередей.

Есть ли какая-либо опция в весенней интеграции, где я могу передать детали своей очереди из конфигурации и соответствующую ейпотребительский компонент должен быть создан и добавлен в контекст моего приложения.

Между тем я использую Java 8 с пружиной 4.3.4

Любая помощь приветствуется !!

Answer 1

Для этой цели мы внедрили Регистрация динамических потоков .

Я понимаю, что вы не можете использовать Spring Integration Java DSL, но не существует простого способа регистрации bean-компонентов во время выполнения.

IntegrationFlowContext также доступно для Spring Integration 4.3.x: вам нужно включить расширение для Java DSL Spring Integration: 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();