メッセージを読むのは、Spring AMQPでカウント可能な回数だけです。

Question

私はRabbitMQからメッセージを受け取るアプリケーションを持っています。メッセージが消費されて何らかの問題が発生した場合私はsetDefaultRequeueRejectedをtrueに設定しました。キューに戻ってきています。

私はシナリオを持っています。メッセージがキューに戻った場合は、再び消費され、再びキューに入れられます。これは一種のサイクルを形成しています。

私は再キューに入れられたメッセージを2回だけ消費する必要があります（カウンタの種類を維持する）。その後、それをErrorQueue/DeadLetter Queueにプッシュします。 このようなカウンタを維持するにはどうすればよいですか？

よろしく、

チャンダン

Answer 1

RabbitMQのようなメカニズム、メッセージが再配信されたことを示すだけブールヘッダーを提供しません。

送信者がmessageIdヘッダーを設定する場合は、stateful retry interceptor withを使用できます。フレームワークは、同じメッセージが何回配信されたかを記録します。 RejectAndDontRequeueRecovererを指定すると、再試行が終わった後でメッセージがDLQに送信されます（設定されている場合）。

メッセージIDがない場合は、カスタムMessageKeyGeneratorを使用して、メッセージ自体から状態のキーを生成できます。