我使用Bunny设置RabbitMQ队列。
上面的代码创建了一个队列,并绑定到路由键“test_cmd”。当我重新启动Rabbitmq服务器时,队列仍然存在,但是队列绑定被删除。
我使用sudo invoke-rc.d rabbitmq-server restart命令来重新启动Rabbitmq。
Rabbitmq版本:RabbitMQ 3.2.4,Erlang R16B03。
这是Rabbitmq的默认行为吗?我该如何保留我的队列绑定?
namespace :rabbitmq do
desc 'Setup routing'
task :setup_test_commands_queue do
require 'bunny'
conn = Bunny.new(ENV['SYNC_AMQP'], read_timeout: 10, heartbeat: 10)
conn.start
ch = conn.create_channel
# get or create exchange
x = ch.direct('testsync.pcc', :persistent => true)
# get or create queue (note the durable setting)
queue = ch.queue('test.commmands', :durable => true, :ack => true, :routing_key => 'test_cmd')
# bind queue to exchange
queue.bind(x, :routing_key => 'test_cmd')
conn.close
end
end
上面的代码创建了一个队列,并绑定到路由键“test_cmd”。当我重新启动Rabbitmq服务器时,队列仍然存在,但是队列绑定被删除。
我使用sudo invoke-rc.d rabbitmq-server restart命令来重新启动Rabbitmq。
Rabbitmq版本:RabbitMQ 3.2.4,Erlang R16B03。
这是Rabbitmq的默认行为吗?我该如何保留我的队列绑定?
x = ch.direct('testsync.pcc', :persistent => true)
。 - dnshx = ch.direct('testsync.pcc', :durable => true)
。 bunny 忽略了参数 persistent,应该是 durable。 - dnsh