Зеркальные очереди с балансировкой нагрузки - PullRequest
0 голосов
/ 31 мая 2019

Я использую ActiveMQ 5.15.8 для целей аудита. Я хочу, чтобы каждое сообщение очереди было доступно в очереди аудита.

Для этого сценария я планирую использовать концепцию «зеркальной» очереди ActiveMQ.

Конфигурация сервера:

<destinationInterceptors>
   <mirroredQueue copyMessage = "true" postfix="" prefix="VirtualTopic.Mirror.*"/>
</destinationInterceptors>

Конфигурация потребителя:

conn.subscribe("Consumer.A.VirtualTopic.Mirror.xyz", 1, ack="auto", headers={"activemq.prefetchSize":1})

Задача

ActiveMQ создает очередь Consumer.A.VirtualTopic.Mirror.xyz очередь для VirtualTopic.Mirror.xyz зеркальной темы.

Но он также создает другую тему под названием VirtualTopic.Mirror.Consumer.A.VirtualTopic.Mirror из-за зеркальной политики, и я также не получаю сообщение в Consumer.A.VirtualTopic.Mirror.xyz.

...