問題タブ [dead-letter]

次のサービス構成を使用して、wcf で配信不能キュー サービスを作成しようとしています。

サービス ホストを開始すると、「無効なキュー パス名」という System.Messaging.MessageQueueException が発生します。トランザクション システムのデッド レター キュー アドレスの何が問題になっていますか? ネットで他の例を見つけることができません。

トランザクション システムのデッド レター キューからデッド レターを読み取るサービスを作成しようとしています。

サービス構成は次のようになります。

私のサービスインターフェース：

私のサービスの実装では：

そして、次のようにホストを起動します。

これまでのところ、すべてが多くの本やチュートリアルで説明されているように見えますが、トランザクションのデッドレター キュー内でデッドレターを生成すると、サービスが呼び出されません。サービスの何が問題になっていますか?

助けてくれてありがとう

メッセージを配信するためのブローカーとして ActiveMQ を使用しています。これらのメッセージは、データベースに書き込まれることを意図しています。場合によっては、データベースに到達できないかダウンしています。その場合、メッセージをロールバックして後でこのメッセージを再試行し、他のメッセージを引き続き読みたいと考えています。

このコードは、1 つの点を除いて正常に動作します。ロールバックされたメッセージが他のメッセージの読み取りを妨げています。

私はこの方法でセッションを作成します:

ロールバックは簡単に尋ねられます:

キューに 3 つのメッセージがあるとします。

私の消費者は（線形シーケンス）を行います：

でも私はしたい ：

では、ロールバックされたメッセージを後で遅らせるように Consumer を構成するにはどうすればよいでしょうか?

VBScript を使用して、配信不能キュー内のメッセージ数を取得しようとしています。これが私のコードです：

これが私が得ているエラーです：

この形式を使用してプライベート メッセージ数を取得していますが、このエラーはデッド レターで表示されます。

RabbitMQ で dlx キューを実装しようとしています。シナリオは非常に簡単です。2 つのキューがあります: 1) 生きている 2) 死んでいる (x-dead-letter-exchange: "immediate", x-message-ttl: 5000)

および 1) 生きているにバインドされている「即時」交換

この例を実行しようとしました: http://blog.james-carr.org/2012/03/30/rabbitmq-sending-a-message-to-be-consumed-later/ しかし、メッセージが後にドロップされたようですttl の有効期限が切れ、取引所で公開されないため、私のアライブ キューは常に空です。

また、管理コンソールで手動でキューを作成しようとしましたが、同じ動作が得られます。

Ubuntu/rabbitmq 3.0.0 と Mac OS X および rabbitmq 2.8.7 でテストしました

何か不足していますか？

ルビーストンプジェムhttps://github.com/stompgem/stompを介して、 x-dead-letter-exchangeおよびx-message-ttlヘッダーを使用してキュー(RabbitMQ)に公開しようとしています

管理パネルからは正常に動作しますが、このコードを使用して公開されたメッセージが表示されません:

「通常の」キューでこれを試すと、メッセージは期待どおりに公開されます。

何かアドバイス？

RabbitMQ Admin (v3) を使用して、エラー キューがバインドされているルーティング キー「MyErrorRoutingKey」を使用して、デッド レター メッセージをデフォルトの交換に送信するキューを作成しようとしました。そのため、管理インターフェイスで、「デッド レター交換」を空白のままにしました。

キューを作成しようとすると、次のメッセージが表示されるのが普通なのだろうか。

406 PRECONDITION_FAILED - vhost '/' のキュー 'MyQueue' の無効な引数 'x-dead-letter-routing-key': routing_key_but_no_dlx_defined

ドキュメントでさらに次のように述べられているため、デッドレターメッセージをデフォルトの交換にルーティングすることは可能と思われます。

配信不能キューのサイクルを形成することができます。たとえば、デッドレタールーティングキーを指定せずに、キューがデフォルトの交換にデッドレターメッセージを送信すると、これが発生する可能性があります。このようなサイクルのメッセージ (つまり、同じキューに 2 回到達するメッセージ) は破棄されます。

では、メッセージをデフォルトの交換にルーティングするにはどうすればよいでしょうか? 上記の「循環的な無用な配信不能メール」とは異なり、メッセージが失われないようにルーティング キーを指定できるようにしたいと考えています。

Jboss SOA プラットフォームにアプリケーションをデプロイしました。パフォーマンスの観点から、jboss-esb.xml で DeadLetterService をコメントアウトしました。そのため、例外が発生したり、メッセージがサード パーティに配信されない場合は、DLQ に送信されません。しかし、現在、次のエラーが発生しています

サードパーティに応答を送信するのに約 5 分かかります。遅延の理由を調べています。

この問題が「DeadLetterService」とどのように関連しているかを誰でも知っていますか? または、どうすれば問題を再現できますか? またはなぜ5分の遅れ？

Spring DSL を使用して次のルートを定義しています。

の出力 (送信メッセージ) によってはfizzBean、Smooks プロセッサが例外をスローし、アプリケーション全体がハングすることがあります。これを行うと、アプリのログに例外がスローされていることがわかります (実際には MySQL の例外です) が、それをラップ/キャッチして処理を続行する方法がわかりません。上記の設定があれば、スローされた MySQL 例外が処理され、ルートが処理を続行すると考えました。代わりに、これらの Smooks/MySQL 例外がスローされたときにメソッドが実行されたErrorCatcherという証拠がアプリ ログに表示されません。ErrorCatcher#handle

ここで何か間違って設定しましたか? そのプロセッサ内から例外がスローされてアプリ全体がハングするのを防ぐために、(Smooks プロセッサの URI 構成などを介して) 他にできることはありますか? 前もって感謝します！