重新启动RabbitMQ后删除Ruby AMQP持久性消息

我有一个 ruby脚本,它在RabbitMQ中使用AMQP创建一条消息.

# above code sets up config for connecting to RabbitMQ via APMQ
AMQP.start(:host => 'localhost') do
  amq = MQ.new
  amq.queue('initiate', :durable => true).publish(message_id, :persistent => true)
  AMQP.stop{ EM.stop }
end

如果重新启动RabbitMQ服务器,则消息不再位于启动队列(或任何队列)中.如果消息不持久,我做错了什么?我还尝试显式创建持久交换,并将队列绑定到该交换,但在RabbitMQ重启后仍然删除该消息.

有趣的是,我只是谷歌搜索同样的问题. RabbitMQ 2.2.0,默认选项.就我而言,Ruby客户端使用EPEL中的rubygem-amqp-0.6.7-3.el5.持久的队列绑定到持久的扇出交换,发布消息:persistent =>真正.服务器重启时丢失的消息. -Alan
相关文章
相关标签/搜索