2015-09-07 27 views
0

以下 https://www.rabbitmq.com/tutorials/tutorial-two-java.html 後,我宣佈我的隊列爲:如何讓rabbitmq在服務器重啓後保留數據?

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

我寫信給排隊的方法如下(如果它使差):

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

,但如果我重新啓動該服務器的所有數據被刪除。

如何在rabbitMQ中聲明一個隊列,以便在服務器重新啓動時保留數據?

回答

2

好吧,這是愚蠢的錯誤

我改變:

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

到:

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

現在它按預期工作。

相關問題