_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