dead-letter

0熱

1答えて

MQクラス（IBM）を使用してJavaのBytesMessageにデッドレターを変換する方法

デッドレターキューからメッセージを再送信したいですか？そのためには、デッドレターをBytesMessage（ペイロードはZIPまたはString）に変換する必要があります。は、私がこれまで試したどのような：）（MQRFH2クラスによってRFH2を取得し、求めて： mqMessage.seek(0); MQRFH2 rfh2 = new MQRFH2(mqMessage); byte[]

1熱

1答えて

Apache Camelで再配信された後にWebサービスを呼び出す方法は？

私は、この問題の解決策を促進するエンタープライズインテグレーションのパターンやレシピを見つけることに失敗しました：再配信の試行が終わった後、Webサービスリクエストを元のソースに送り返す必要があります。失敗した配信を送信者に通知する。すべての再配信試行が尽きると、メッセージをデッドレターキューに移動する必要がありますか？次に、そのDLキューでリッスンする新しいコンシューマーを作成しますか？ソー

0熱

1答えて

Fのデッドレターを購読して表示する方法

デッドレターを表示/キャプチャするために以下のコードを試しましたが、それはすべきではありません。私が行方不明になっている。正確には？私の目的は、デッドレターの俳優に配信されているすべての死んだ手紙を見るだけです。 let system = ActorSystem.Create("FSharp") let echoServer = spawn system "EchoServer" <| f

0熱

3答えて

デッドレターメッセージを覗く方法

デッドレターキュー内のすべてのメッセージを取得し、それらを覗き込むことについては、いくつかの良い文書を見つけるのは非常に難しいです。私はAzureのサービスバス待ち行列を持っています。私が見つけることができるものはサービスバストピックです...誰かが簡単なガイドで私を助けることができますか？

6熱

2答えて

RabbitMQ - Apache Camel読んでいるメッセージ失敗したメッセージの処理方法

次のPHPアプリケーションがあります。これにより、ユーザーのサインアップがメッセージキューにパブリッシュされます。 Javaアプリケーションはそのキューから読み込み、それをインポートします。うまくいけば、以下のダイアグラムがそれを討論するでしょう。私は物事のJava側でのみ作業しています。 jsonメッセージはすでにキューに存在します。ルート（Javaはサイドを消費）。 @Component

0熱

1答えて

一貫性のあるハッシュ交換でバインドされた期限切れキューのデッドレターメッセージ

特定のソースに関連するイベントを処理している状況があります。各ソースにはキーまたはIDがあり、これをハッシュとして使用できます。各ソースからのイベントを順番に処理する必要がありますが、異なるソースからのイベントを並列化して水平スケーラビリティを実現できます。何百ものソースキーがあります。メッセージをRabbitMQに送信するときに、ルーティングキーの一部としてキーを設定してから、consiste

0熱

1答えて

Akka-Javaは依頼待ちでDeadLetterExceptionをスローしています

私はこのようなファイルにドライバ/メインクラスを持っています。（基本的に私はSTORM & AKKAを混ぜようとしています）。 TenderEventSpout2クラスでは、俳優との間でメッセージの送受信をしようとしています。 public class TenderEventSpout2 extends BaseRichSpout { ActorSystemHandle actorS

5熱

1答えて

RabbitMQのデッドレターの扱い

TL; DR：もともとメッセージが拒否されていたコンシューマーコードを修正したら、デッドレターメッセージを元のキューに「再生」する必要があります。 RabbitMQのデッドレターエクスチェンジ（DLX）を設定し、拒否されたメッセージをデッドレターキューに正常にルーティングしました。しかし今、私はデッド・レター・キュー内のメッセージを見て、それぞれの処理方法を決定しようとします。問題のコンシューマコ