0

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

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

RabbitMQ 立即将所有消息从 移动READYUNACKED,因此在READY.

如果我尝试使用相同的代码启动另一个兔子,它现在没有什么可读取的了READY

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

4

1 回答 1

5

弄清楚了。我没有设置pre_fetch

于 2015-08-04T23:42:58.193 回答