問題タブ [dead-letter]

Erlang クライアントから Dead Letter Exchange を送信したいのですが、数日間試してみましたが、Ruby クライアント経由で簡単に送信できる一方で、方法がわかりません。

ありがとう

JAVA で Azure Service Bus キューから配信不能メッセージを読み取ることができるかどうかを知りたいです。

次の例を見つけましたhttps://code.msdn.microsoft.com/windowsazure/Brokered-Messaging-Dead-22536dd8/sourcecode?fileId=123792&pathId=497121593 ただし、コードを Java に変換できていません。

https://github.com/Azure/azure-storage-java/tree/master/microsoft-azure-storage/src/com/microsoft/azure/storageも見つかりまし たが、デッドレットについては何もないようです。まったく。

また、いくつかのブログも見つけました (これ以上リンクを張ることは許可されていないため、適切なタグを付けずにリンクを張るべきかどうかわかりません)。しかし、それらはすべて、JAVA で配信不能メッセージを読み取る方法を説明しているわけではありません。

よろしくお願いします

いくつかのプラグイン（管理プラグイン）を介してデッドレター交換で少数のメッセージを超えた後に自動的にDLに通知するためのrabbitMQ（設定可能）独自の方法はありますか？

このチュートリアルでデッド レター (ポイズン) キューで説明されているように、Web ジョブ SDK で Azure のサービス バスを使用しています。簡単にするために、POCO キュー メッセージを使用しています。メッセージ処理関数が何度も失敗すると、メッセージは配信不能キューに移動されます。

何か問題が発生したことをチームに通知するために、デッド レター キューを使用する別の Web ジョブがあります。

メッセージが配信不能キューに移動された例外/理由を取得する方法はありますか? たとえば、POCO メッセージがシリアル化に失敗したためにデッド レター キューに移動された場合、それを見つける最善の方法は何ですか?

エラーを手動で処理したり、自分でメッセージを配信不能キューに入れたりすることは避けたいと思います。webjobs SDK は、これらすべてを見事に実行します。

Microsoft Azure の私の DeadLetter キュー (トピック用) には、現在 60,000 レコードが含まれています。これをクリアしたいのですが、これを行う方法に関する情報が見つからないようです。サービス バス エクスプローラーを使用してみましたが、1000 個のアイテムを削除しようとするだけで時間がかかりました。

1 つのステートメントでこれを行うことは可能ですか、それともトピックを削除して再作成する必要がありますか。

デッドレター交換/キューがよくわかりません。オンラインドキュメントには次のように書かれています：

これらのイベントが発生すると、メッセージは自動的に配信不能キューに移動されるということですか? または、これらの「デッド」メッセージをその DLQ に移動するには、コードで具体的にする必要がありますか?

また、通常のキューに DLX/DLQ をセットアップするにはどうすればよいですか? 通常のキューのメッセージが失敗/期限切れになった場合、DLX/DLQ に移動しますか?

次のPHPアプリケーションがあります。これにより、ユーザーのサインアップがメッセージ キューにパブリッシュされます。Java アプリケーションはそのキューから読み取り、インポートします。うまくいけば、下の図がそれを説明します。私は Java 側の作業のみを行っています。json メッセージは既にキューに存在します。

ルート (Java 消費側)。

プロセッサは..

私の質問はこれです.プロセッサがメッセージのインポートに失敗した場合、どうすればよいですか。

たとえば、DAO 例外があったとします。データ フィールドが長すぎるか、インポートの形式が正しくない可能性があります。メッセージを失いたくない。エラーを確認して、インポートを再試行したいと思います。しかし、30 秒ごとにメッセージを再試行し続けたくありません。

別のキューを作成する必要があると考えています.デッドレターキューで、6時間ごとに無期限にメッセージを再試行しますか?..次に、ログを表示してエラーを確認し、修正をアップロードすると、メッセージが再処理されますか?

どうすればそれを実装できますか？それとも私は間違った道を進んでいますか？

EDIT 私はdeadLetterExchangeを設定して、物事が正しい方向に進むかどうかを確認しようとしました...しかし、エラーが発生し、キューを非nullにすることはできません

このトピックに関する複数の回答を読みましたが、構成は適切に機能するはずですが、何らかの理由で機能しません。

構成は次のとおりです。

RabbitMQ UI は、応答キューにDLXとDLK属性があることを示しています。

みたいなメッセージを送ります

メッセージ ハンドラーAmqpRejectAndDontRequeueExceptionは、メッセージを受信した直後にスローします。これは、テストのみを目的として意図的に行われます。再試行のアドバイスから始めましたが、結果が得られなかったため、テスト ケースを単純化しました。

現在、次の 2 つの問題が発生しています。

1. ARADRE がスローされた後、メッセージが DLQ に表示されません。でも直接DLQにパブリッシュすればOKhandleMessageです。
2. convertSendAndReceive何も返されず（例外かもしれませんか？）、タイムアウトが発生するまで待機します。これは私の場合は5分です。意図したものかもしれませんが、RPC スタイルの呼び出しの場合はかなり奇妙です。

何かを見逃したり、設定を誤ったりしましたか?