が一時的に後で

Question

私はJavaのRabbitMQのクライアント（https://mvnrepository.com/artifact/com.rabbitmq/amqp-client）を使用して、私は次のシナリオを実装する必要がRabbitMQのメッセージを消費して停止し、再開：ウサギのメッセージを受信して​​いる間

• を、私は特定のキューからRabbitMQの消費量を一時停止する必要があるかもしれません私がデータを待っているすべてがメモリに収まらないと思われるならば。
• いくつかのメッセージを処理した後、次のメッセージのセットに対して再び消費を開く必要があります。
• 必要に応じて繰り返します。

amqp-client Javaライブラリを使用してRabbitMQキューからのリスニングの一時停止/再開を実装する最善の方法はありますか？

Answer 1

メッセージを消費する方法については言及していませんので、basicConsumeを使用してキューからメッセージを購読しているとします。

that documentには、basicCancelを使用してキューからの消費を停止できます。再度開始する場合は、basicConsumeを使用します。

適切なプリフェッチ数を設定するには、必ずbasicQosを使用してください。