如何让 Bunny 使用 RabbitMQ 一次处理一条消息？

Question

当我使用 Bunny 时，当我使用以下命令打开到包含 50,000 条消息的队列的连接时：

queue = channel.queue('test.queue', :durable => true)
queue.subscribe(:manual_ack => true) do ...

RabbitMQ 立即将所有消息从 移动READY到UNACKED，从而不会在 中留下任何消息READY。

如果我尝试使用相同的代码启动另一个兔子，它现在没有任何可读取的内容READY。

我错过了一些明显的东西吗？

Answer 1

弄清楚了。我没设置pre_fetch。