1

BrokerApplicationFlow内の入力および出力としてWebsphereMQを使用しています。フローには、Websphere TransformationExtenderMapsも含まれています。

javaを使用して、入力キューで一意の識別子を持つメッセージを送信し、出力キューで応答を受信したいと思います。その一意の識別子を使用して、出力キューからメッセージを選択できるはずです。

これどうやってするの?

4

1 に答える 1

4

これを行う簡単な方法は、CorrelationID を使用することです。

要求を処理しているアプリケーションは、応答時に MessageID を応答メッセージの CorrelationID にコピーする必要があります。リクエスター アプリケーションは、メッセージの受信中にメッセージ セレクターとして CorrelationID を指定し、セレクターの値として要求メッセージの MessageID を提供します。

JMS を使用する場合は、はるかに簡単になります。JMSMessageID および JMSCorrelationID プロパティを使用し、JMSCorrelationID をセレクターとして持つコンシューマーを作成します。

QueueReceiver queueReceiver = session.createReceiver(destination, "JMSCorrelationID='+ requestMsg.JMSMessageID +"'");

于 2012-04-16T03:58:17.547 に答える