首页 > 编程语言 > 详细

Java使用Rabbitmq惊喜队列queue和消息内容的本地持久化核心方法。(内容存储在硬盘)

时间:2017-03-31 11:53:46      阅读:667      评论:0      收藏:0      [点我收藏+]
_Channel.queueDeclare(queue, true, false, false, null);
_Channel.basicPublish(_ExchangeName, queue,MessageProperties.MINIMAL_PERSISTENT_BASIC, bodyBytes);

常常遇到rabbitmq service停止以后,重启,发现mq里的东西也丢失了。

_Channel.queueDeclare(queue, true, false, false, null);  //标红的参数表示要持久化queue。durable = true
_Channel.basicPublish(_ExchangeName, queue,MessageProperties.MINIMAL_PERSISTENT_BASIC, bodyBytes); //表示消息需要持久化到硬盘

Java使用Rabbitmq惊喜队列queue和消息内容的本地持久化核心方法。(内容存储在硬盘)

原文:http://www.cnblogs.com/haoliansheng/p/6650504.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!