当我使用 Bunny 时,当我使用以下命令打开与包含 50,000 条消息的队列的连接时:
queue = channel.queue('test.queue', :durable => true)
queue.subscribe(:manual_ack => true) do ...
RabbitMQ 立即将所有消息从 移动READY
到UNACKED
,因此在READY
.
如果我尝试使用相同的代码启动另一个兔子,它现在没有什么可读取的了READY
。
我错过了一些明显的东西吗?