私は ActiveMQ を使用していますが、この特定のケースを解決する方法を知りたいです。
コンシューマーが停止すると、プロデューサーはメッセージをキューに送信します。メッセージは、消費者がそれを消費するために実行されるまで、キューに残ります。
プロデューサーをシャットダウンすると、メッセージはまだキューに残ります。ここでコンシューマーを実行すると、そのメッセージを消費しようとしますが、ダウンしてからプロデューサーに返信できなくなります。
プロデューサーが不在の場合、メッセージを消去することでこの問題を解決したいと思います。ActiveMQ ブローカは、停止後にキューを消去します。それぞれのプロデューサーのメッセージについても同じことをしたいと思います。
ありがとう。