Spring-integration/ActiveMQ подписаться на несколько адресов в одном потоке

Question

Я использую несколько <si:service-activator> и <jms:message-driven-channel-adapter>, чтобы подписаться на несколько очередей и тем. Сообщения от каждого получателя принимаются в отдельном потоке, что означает, что мой код приема заполнен замками для защиты изменчивого внутреннего состояния.

Я хочу, чтобы мой код получения был заблокирован. Можно ли настроить функцию spring-integration/activemq для приема из нескольких пунктов назначения в одном потоке?

Если это не возможно, я могу думать о двух альтернатив:

1. Начните свой собственный поток обработки, которая считывает из очереди блокировки, положить все полученные сообщения в этой очереди.

2. Отправляйте все полученные сообщения в один пункт назначения и используйте их.

У кого-нибудь есть идеи?

Answer 1

Используйте wildcard pattern в одной очереди.

То есть вместо чтения из двух очередей используйте одну очередь и укажите все очереди, из которых вы хотите читать.

, а именно: "QUEUE.NR1,QUEUE.NR2" или "SOME.PREFIX.>", чтобы прочитать все очереди с этим префиксом. Код клиента обрабатывает это как одну очередь.