Bunny を使用する場合、次を使用して 50,000 件のメッセージがあるキューへの接続を開くと:
queue = channel.queue('test.queue', :durable => true)
queue.subscribe(:manual_ack => true) do ...
RabbitMQ はすべてのメッセージを からREADYにUNACKED即座に移動するため、 には何も残りませんREADY。
同じコードを使用して別のバニーをスピンアップしようとすると、読み取るものが何もなくなりますREADY。
明らかな何かが欠けていますか？