Добавление очереди в RabbitMQ Listener после запуска Listener - PullRequest
Новая
       4

Добавление очереди в RabbitMQ Listener после запуска Listener

2 голосов
/ 05 июля 2011

Я использую SimpleMessageContainerListener. У меня есть несколько очередей, необходимых для прослушивания с одним и тем же потребителем. Но очереди будут создаваться динамически после того, как слушатель настроен и запущен. Я не могу перейти к теме из-за требования приложения.

Я использую Spring AMQP. Вот моя конфигурация: 

<bean id="listenTest" class="org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer" 
p:connectionFactory-ref="connectionFactory" p:queueNames="testQueue1" 
p:messageListener-ref="messageListenerAdaptor" p:concurrentConsumers="2" p:prefetchCount="2" 
p:acknowledgeMode="MANUAL" p:channelTransacted="true"
/>

В приведенной выше конфигурации потребитель прослушивает очередь 'testQueue1'. Я хочу добавить больше очередей: «testQueue2» и «testQueue3», которые будут прослушиваться одним и тем же слушателем / потребителем после загрузки bean-компонентов.

...