私はactiveMQキューでメッセージを送信し、要求で作成された一時キューの応答をリッスンする青写真を使用してラクダルートを作成しようとしています。これはかなり基本的なようですが、私はそれを利用する例を見つけることができません。私はここで検索し、ドキュメントを読んで試している私のラクダルートでActiveMQから応答をキャプチャしようとしています
は、私が見つけたものです:イライラさせられる http://camel.apache.org/jms.html http://camel.apache.org/exchange-pattern.html http://camel.apache.org/request-reply.html https://access.redhat.com/documentation/en-US/Red_Hat_JBoss_Fuse/6.0/html/EIP_Transaction_Guide/files/FMRTxnJMSSynchronous.html http://kosalads.blogspot.com/2014/04/ApacheCamelRequestReplyPatternWithJavaDS.html http://grokbase.com/t/camel/users/128n88xeva/how-to-use-request-reply-in-jms http://camel.465427.n5.nabble.com/ExchangePattern-InOut-I-Can-t-get-any-response-td5056301.html https://examples.javacodegeeks.com/enterprise-java/apache-camel/apache-camel-exchange-example/
。
私は私のActiveMQコンポーネントは、このようなを設定している:
<to pattern="InOut" uri="activemq:queue:tripRequest.updateStatus.v1.0?useMessageIDAsCorrelationID=true"/>
<log message="Update Status responded ${out.body}"/>
ログには、私を驚か入力XMLを示しています。ドキュメントをチェックした後、同じキューを待ち受けてログにダンプする新しいactiveMQインスタンスを作成しましたが、これによってエラーがスローされ、別のルートのログとアンマーシャルオブジェクトが混ざり続けます。
どうすればこの問題を解決できますか?
レスポンスを聞くのはどういう意味ですか?適切なリクエスト/応答を意味するので、activemqは一時的なレスポンスキューを作成しますか?あるいは、非同期要求/応答を意味しますか?また、あなたの質問から何が間違っているのか分かりにくいです。あなたのルートと、あなたが何を期待しているのか、そしてあなたが実際に見ているものを共有した方が良いでしょう。 –
@SoucianceEqdamRashti私は、質問に役立つと感じるルートの唯一の部分を共有しました。問題は、私が次の作品を作る方法を知らないことです。私のルートは単にactiveMQコールで終了します。私は応答を処理するために一時的な応答キューを使用したい。私は質問を更新します。 – Thom