Я использую 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
.