ActiveMQ每一个queue中消息只能被一个消费者消费,然而,有时候,你希望能够监视生产者和消费者之间的消息流。
MirroredQueue: Broker会把发送到某一个队列上的所有消息转发到一个名称类似的topic,因此监控程序只需要订阅这个topic.为启用MirroredQueue,首先要将BrokerService的useMirroredQueues属性设置为true:
<broker xmlns=http://activemq.apache.org/schema/core useMirroredQueue="true">
</broker>
然后可以通过destinationInterceptors设置其属性,如mirrortopic的前缀,缺省是VritualTopic.Mirror.
修改后缀的配置示例:
<broker xmlns="http://activemq.apache.org/schema/core">
<destinationInterceptors>
<mirroredQueue copyMessage="true" postfix=".qmirror" prefix="" />
</destinationInterceptors>
</broker>