如何跟踪对WebSphere MQ上消息的回复？

Question

我正在使用Websphere MQ作为Broker Application Flow中的输入和输出。该流程中还包含Websphere Transformation Extender Maps。

我想用java在输入队列中发送带有唯一标识符的消息，并在输出队列上接收回复。我应该能够使用该唯一标识符从输出队列中选择消息。

我该怎么做？

Answer 1

执行此操作的简单方法是使用CorrelationID。

处理请求的应用程序需要在响应时将MessageID复制到回复消息的CorrelationID。请求者应用程序在接收消息时将CorrelationID指定为消息选择器，并将请求消息的MessageID作为选择器的值提供。

如果您打算使用JMS，那么它会简单得多。使用JMSMessageID按和JMSCorrelationID属性和与JMSCorrelationID创建消费者为选择

的QueueReceiver的QueueReceiver = session.createReceiver（目的地， “JMSCorrelationID ='+ requestMsg.JMSMessageID +”'“）;