問題タブ [wso2mb]

WSO2 Message Brokerを個別に使用してみましたが、問題なく動作します。

実際、送信者と受信者として機能する 2 つの別個の Java アプリケーションを作成しました。どちらのアプリケーションも amqp 接続文字列を使用して接続を開始します。Apache Ant サーバーを使用してアプリケーションを構築しました。

ここで、Message Broker を WSO2 ESB と統合したいと考えています。

ESB を使用して Web アプリケーションで Message Broker を使用する最良の方法を教えてください。

時々混同してしまいますが、

混乱 1 :メッセージ ストアとメッセージ ブローカの違い。

混乱 2 : Web アプリケーションは、メッセージ ブローカーを使用するために接続文字列を必要としますか?

Spring JMS を使用して WSO2MB サーバーに接続しています。すべて正常に動作していますが、すべてのリスナーに同じ ID が割り当てられています。一意にするために clientId を指定しましたが、機能していません。名前を入力できる他のフィールドが見つかりません。

JMS リスナーに id を指定しましたが、成功しませんでした。

私はWSO2 ESBの初心者で、次の問題があります。

私のESBフローには、XML ドキュメントをWSO2 MBキューに入れるStore メディエータがあります。これが私のメッセージ ストアの構成です。

ご覧のとおり、ドキュメントはglisQueueキューに入れられます。

次に、(このプロジェクトで) glisMessageProcessorという名前のメッセージ プロセッサをデプロイしました。このメッセージ プロセッサは、キューが空ではないかどうか、送信先の XML ドキュメントと Http 呼び出しを実行する外部 Web サービスが含まれているかどうかをチェックします。これが私のメッセージ プロセッサの構成です。

ご覧のとおり、データ ソースとしてglisMessageStoreを使用しているため (送信するデータを取得するためにglisQueueキュー定義を使用しています)、これらのデータをWeb サービスのエンドポイントであるglisEndpointに送信しています (私のプロジェクト）。

正常に動作し、データはglisEndpointによって表される外部 Web サービスに正しく送信されます。

私の唯一の問題は、Web サービスが呼び出されたときにメッセージを返すことです (何らかの方法で保存する必要がある情報が含まれています)。

これらの応答メッセージを取得してログ ファイルに記録するように、 glissMessageProcessorを何らかの方法で構成できますか?

ofを使用してof にいくつかのjsonコンテンツを挿入しました:queueWSO2 Message BrokerAPIWSO2 ESB

このでは、 の応答APIを反復処理し、これを使用して注文を 1 つに挿入しました。jsonendpointMessage Broker's queuesequence

次に、これらのメッセージを orders_mbで消費し、別の で使用したいので、 Message Processoratを作成しました。とのコードは次のとおりです。WSO2 ESBqueuesequenceMessage StoreMessage Processor

最後に、 がのメッセージを送信するのは次のsequenceとおりです。Message Processorqueue

API resourceに注文を挿入するために を呼び出すと、queue機能します。ただし、Message Processor消費するとログアウトします

[2017-07-13 10:06:34,856] 警告 - JmsConsumer [orders_mb-C-1]。javax.jms.ObjectMessage を受け取りませんでした

何が問題なのかわかりません。同じ問題について質問するこの質問を見ましたが、必須のプロパティを既に挿入しており、ここではまだ機能していません。