我正在编写一个小应用程序,其中使用了RabbitMQ来发送/接收消息。一切都运行良好,但是我在处理消息持久性方面遇到了困难。
我希望消息即使在服务器重新启动时也能保留在队列中。我理解交换机和队列级别的耐久性概念,并将它们设置为true(或者它们默认为true)。因此,当我重新启动RabbitMQ服务器时,交换机和队列仍然完好无损,但是队列中的消息被删除了。
我正在使用EasyNetQ.IBus接口发送消息。
谢谢
我希望消息即使在服务器重新启动时也能保留在队列中。我理解交换机和队列级别的耐久性概念,并将它们设置为true(或者它们默认为true)。因此,当我重新启动RabbitMQ服务器时,交换机和队列仍然完好无损,但是队列中的消息被删除了。
我正在使用EasyNetQ.IBus接口发送消息。
谢谢
_bus = RabbitHutch.CreateBus("host=abc;virtualHost=def;username=a;password=b;persistentMessages=true");
。我已经阅读过默认情况下持久性为真,但在我的情况下似乎并非如此。现在我正在手动设置message.properties.DelievryMode = 2
并测试。 - Jay