服务器重启后如何让rabbitmq保留数据？

Question

关注之后 https://www.rabbitmq.com/tutorials/tutorial-two-java.html 我将队列声明为：

//first true is for durable so it should survive restart
channel.queueDeclare(queName, true, false, false, null);

我写入队列的方式如下（如果有区别的话）：

channel.basicPublish("", queName, null, string.getBytes());

但是如果我重新启动服务器，所有数据都会被删除。

如何在rabbitMQ中声明一个队列，如果服务器重新启动，将保留数据？

Answer 1

好吧，这是个愚蠢的错误

我变了：

channel.basicPublish("", queName, null, string.getBytes());

到：

channel.basicPublish("", queName, MessageProperties.PERSISTENT_TEXT_PLAIN, string.getBytes());

现在它按预期工作了。