使用 Camel 设置 IBM MQ 请求消息的 MQMD 的 ReplyToQ 属性

Question

我将 Camel 与 Fuse 一起使用，但无法设置 JMSReplyTo。以下是我路线的摘录：

<setHeader headerName="JMSReplyTo" id="_setHeader2">
    <constant>QTEST</constant>
</setHeader>
<setHeader headerName="CamelJmsDestinationName" id="_setHeader1">
    <constant>queue://QM_TEST/SYSTEM.DEFAULT.LOCAL.QUEUE?targetClient=1</constant>
</setHeader>
<to id="_to1" uri="websphere:queue:SYSTEM.DEFAULT.LOCAL.QUEUE?replyTo=QTEST"/>

我以这里给出的代码为例： Implementing native websphere MQ with CoD over Camel JMS component 起初，我认为这是因为我在 CamelJmsDestinationName 标头中设置了 targetClient=1 指令删除了不需要的 jms 标头，但即使没有它，它也不会为 MQMD 的 ReplyToQ 属性设置任何内容。我也试过这里给出的建议How to send message to different Queue hosted in different queue manager and hostname in IBM MQ cluster，但这对我也不起作用，就是这样：

queue://QM_TEST/QTEST?mdReadEnabled=true&messageBody=0&mdWriteEnabled=true&XMSC_WMQ_REPLYTO_STYLE=1&targetClient=1

问题是为什么它不起作用？

Answer 1

我已经弄清楚如何设置ReplyToQ 属性，但这只是我现在面临的问题的一部分。如此处所述，在 JMS Producer 章节中：

http://camel.apache.org/jms.html

只需要这样：

        <setHeader headerName="CamelJmsDestinationName" id="_setHeader1">
            <constant>queue://QMib_TEST/OUTPUTQ?targetClient=1</constant>
        </setHeader>
        <to id="_to1" uri="websphere:queue:SYSTEM.DEFAULT.LOCAL.QUEUE?replyTo=REPLYQ" pattern="InOut"/>

它的作用是将请求消息发送到 OUTPUTQ，然后侦听 REPLYQ，但会匹配一些自动生成的关联 ID。好事是，ReplyToQ 现在在请求消息中设置为 REPLYQ，由于 pattern="InOut" 设置，坏事是在我们的例子中，回复应用程序通过将 Correlation ID 设置为收到请求的消息 ID 进行响应，全部来自 MQMD，并且默认情况下，此 Camel 模式不会在请求的 MQMD 中生成等于它期望的（JMS？）相关 ID 的消息 ID，因此即使将响应放入正确的队列，该响应仍保留在队列中，不被消耗。事实上，它甚至会在 get 等待间隔过后重复发出请求，从而产生更多未在 REPLYQ 中使用的响应消息。所以，这是我必须解决的另一个问题，如何正确处理 MessageID 和 CorrelationID，但我已经解决了这个问题。