問題タブ [dead-letter]

メッセージのヘッダーで定義されたディレクトリにデッド レターをリダイレクトする必要があります。

私はこれを試しました：

私が取得するのは次のような URI です: deadLetter\header{code1}\header{code2}\header{code3}\TIMESTAMP.msg

ルートを構築できるように、これらのヘッダーを取得する方法はありますか?

私は次の構成を持っています

anoter-queueとconsumer.queueに DLX を設定して、メッセージが1 秒後にconsumer.exchange-dlに移動されるようにしました。

another-exchange (直接)にバインドされているanother-queueでは、すべてが正常に機能します。consumer.exchange (トピック)に送信されたメッセージは DLX に移動されません。DLX のルーティング キー バインディングを試してみましたが、何も機能しませんでした。トピック交換のための DLX に関する落とし穴はありますか?

ありがとう

以下のようなデッドレターチャネルエラーハンドラを作成しています

Bean MyErrorProcessor は、以下のようなすべてのタイプのチェック済みおよび未チェックの例外を処理できる必要があります。

しかし、例外が処理された後、元のメッセージはルートのエンドポイントにリダイレクトされる必要があります..このように例外が処理されたら、ルートを続行するには??

メッセージに NACK を送信し、それがデッド レター交換/キューに送信されたときに、それが永続的であることを確認する方法はありますか? 元のメッセージが SetPersistent(true) で永続として設定されていても、デフォルトではデッド レター メッセージはスイートに従っていないようです。

私は最近、メッセージを遅らせることができるRabbitMQ機能を発見しました。必要なものに似た例は見つかりませんでしたが、うまく機能します。

A、B、C の 3 種類のメッセージがあるとします。1 時間と 2 時間の値を持つ 2 つの delay_queue があり'x-message-ttlます。また、destination_queues には 3 つのタイプがあり、それぞれが特定のメッセージ タイプに対応しています。

私が達成したいのは、delay_queues の 1 つのメッセージが TTL に達した後、そのタイプに応じて destination_queues の 1 つにルーティングされることです。このようなもの：

これは、RabbitMQ メッセージ プロパティを使用しても可能ですか? 何か案は？メッセージを遅延キューに送信するコード (有効期限が切れると、hello キューに送信されます):

次のようなデッド レター チャネルで設定された Camel ルートがあります。

正常に動作していますが、メッセージが配信不能チャネルに送信される前に発生した再配信の数を保存する必要があります。私は useOriginalMessage() を使用していることに注意してください。これは、配信不能チャネルに保存したいメッセージです (はい! 私のルートは途中で変更します)。

メッセージ ヘッダー Exchange.REDELIVERY_COUNTER で再配信の回数にアクセスしようとしましたが、メッセージが deadLetterService Bean に到達すると、常に null になります。元のメッセージにはこのヘッダー情報がないため、そうであると理解しています。

再配信カウンターを保持し、同時に元のメッセージを復元するにはどうすればよいですか? それを行う方法はありますか？

前もって感謝します。

ヘレノ