アプリケーションにRabbitMQを使用しています。メンテナンスのために消費者を止める必要がある場合があります。したがって、キューで待機しているメッセージは数千になります。コンシューマーを再起動した後、メッセージ配信率が高くなっています(1秒あたり500〜600メッセージ)。そのレートでは、私の消費者の1人がメッセージを処理してサーバーを故障させることができません。
将来的にコンシューマーコードを変更しますが、今は簡単な解決策が必要です。
では、配信速度を遅くする方法はありますか?basicQosメソッドを試しましたが、うまくいきませんでした。
注:私はコンシューマーにJavaを使用しています。