ActiveMQ学习笔记(9)-镜像队列
2017-08-07 00:00
239 查看
队列中的消息只能被一个消费者消费,如果我们希望能够监视生产者和消费者之间的消息流,可以使用镜像队列。
镜像队列:broker会把发送到某个队列中的所有消息转发到一个名称类似的主题中,因此监控程序可以监听这个主题。
为了启用镜像队列,需要在activemq.xml中将broker的useMirroredQueues设置为true,然后通过destinationInterceptors设置其它属性。镜像主题的前缀(prefix)默认为“VirtualTopic.Mirror. ”。
下面给出一个具体的配置示例。
向队列Queue.Tool发送消息,那么生产者端的代码
主题订阅者端的代码,注意前缀和队列名的拼接,莫因为“.”出错。
镜像队列:broker会把发送到某个队列中的所有消息转发到一个名称类似的主题中,因此监控程序可以监听这个主题。
为了启用镜像队列,需要在activemq.xml中将broker的useMirroredQueues设置为true,然后通过destinationInterceptors设置其它属性。镜像主题的前缀(prefix)默认为“VirtualTopic.Mirror. ”。
下面给出一个具体的配置示例。
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" useMirroredQueues="true"> <transportConnectors> <transportConnector uri="tcp://localhost:61616"/> </transportConnectors> <destinationInterceptors> <mirroredQueue copyMessage = "true" prefix="Mirror.Topic."/> </destinationInterceptors> …… </broker>
向队列Queue.Tool发送消息,那么生产者端的代码
String subject = "Queue.Tool"; …… Queue queue = session.createQueue(subject);
主题订阅者端的代码,注意前缀和队列名的拼接,莫因为“.”出错。
String subject = " Mirror.Topic.Queue.Tool"; …… Topic topic = session.createTopic(subject);
相关文章推荐
- ActiveMQ学习笔记(10)-镜像队列
- Windows RabbitMQ 镜像队列 (高可用性、一台宕机自动切换另一台) 使用 RabbitMQ 自带的Web 管理工具
- RabbitMQ如何保证发送端消息的可靠投递-发生镜像队列发生故障转移时
- 消息队列-ActiveMQ学习笔记(一)-JMS介绍与环境搭建
- 消息队列-ActiveMQ学习笔记(二)-点对点消息实现
- 消息队列-ActiveMQ学习笔记(三)-发布-订阅消息模式实现
- rabbitmq配置集群和镜像队列
- ActiveMQ 镜像队列Mirrored Queues
- Rabbitmq创建镜像队列时的注意事项
- 二叉树镜像之递归、栈、队列实现
- 单机磁盘故障引发RabbitMQ镜像队列数据丢失
- rabbitmq——镜像队列
- 单机磁盘故障引发RabbitMQ镜像队列数据丢失
- rabbitmq集群和镜像队列
- RabbitMQ镜像模式双节点部署时故障转移过程中队列中消息的状态
- 消息队列-ActiveMQ学习笔记(一)-JMS介绍与环境搭建
- RabbitMQ镜像队列初始化连接时的“优化”
- 消息队列-ActiveMQ学习笔记(二)-点对点消息实现
- rabbitMQ的集群方式和镜像队列
- linux(deepin15.4)下部署集群RabbitMQ消息队列镜像模式(三)