我所能得到的最好的记录在下面，说明为一个 Spring XML 应用程序上下文，它本身托管 CAMEL 上下文和路由。它与 IBM 本机 MQ JCA 兼容的资源适配器 v7.5、CAMEL 2.15、Spring core 4.2 一起使用。我可以将它部署到 Glassfish 和 Weblogic 服务器。
考虑到众多变量，在实际实现中当然会使用 java DSL。这个基于 CAMEL XML DSL 的示例是独立的，易于测试。
我们从 Spring 和 Camel 声明开始：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:camel="http://camel.apache.org/schema/spring"
xmlns:jee="http://www.springframework.org/schema/jee"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd">
CAMEL 上下文遵循 2 条路线：MQ 到 JMS 和 JMS 到 MQ，这里链接起来形成一个桥梁以简化测试。
<camel:camelContext id="mqBridgeCtxt">
<camel:route id="mq2jms" autoStartup="true">
奇怪：当使用本机 MQ 资源适配器时，获得（例如）3 个侦听器的唯一方法是强制执行 3 个连接（依次使用 3 个 Camel:from 语句），每个连接最多 1 个会话，否则会出现 MQ 错误：@ 987654325@。但是，如果您改用 MQ 客户端 jar，则 CAMEL JMS 中的 concurentConsumers 选项可以正常工作。
<camel:from uri="wmq:queue:TEST.Q1?concurrentConsumers=1&disableReplyTo=true&
acknowledgementModeName=SESSION_TRANSACTED"/>
<camel:from uri="wmq:queue:TEST.Q1?concurrentConsumers=1&disableReplyTo=true&
acknowledgementModeName=SESSION_TRANSACTED"/>
<camel:from uri="wmq:queue:TEST.Q1?concurrentConsumers=1&disableReplyTo=true&
acknowledgementModeName=SESSION_TRANSACTED"/>
上面的 disable disableReplyTo 选项确保 CAMEL 在我们测试 MQ 消息类型为 1=Request(-reply) 或 8=datagram（一种方式！）之前不会产生回复。此处未说明测试和回复结构。
然后我们在下一次发布到普通 JMS 时将 EIP 强制为 InOnly，以与 Inbound MQ 模式保持一致。
<camel:setExchangePattern pattern="InOnly"/>
<!-- camel:process ref="reference to your MQ message processing bean fits here" / -->
<camel:to uri="ref:innerQueue" />
</camel:route>
接下来是 jms-to-MQ 路由：
<camel:route id="jms2mq" autoStartup="true">
<camel:from uri="ref:innerQueue" />
<!-- remove inner message headers and properties to test without inbound side effects! -->
<camel:removeHeaders pattern="*"/>
<camel:removeProperties pattern="*" />
<!-- camel:process ref="reference to your MQ message preparation bean fits here" / -->
现在是远程目标返回的 MQ CoD 报告的请求标志。我们还强制 MQ 消息为数据报类型（值 8）。
<camel:setHeader headerName="JMS_IBM_Report_COD"><camel:simple resultType="java.lang.Integer">2048</camel:simple></camel:setHeader>
<camel:setHeader headerName="JMS_IBM_Report_Pass_Correl_ID"><camel:simple resultType="java.lang.Integer">64</camel:simple></camel:setHeader>
<camel:setHeader headerName="JMS_IBM_MsgType"><camel:simple resultType="java.lang.Integer">8</camel:simple></camel:setHeader>
ReplyTo 队列可以通过 ReplyTo uri 选项指定，也可以作为下面的标头指定。
接下来我们使用 CamelJmsDestinationName 标头来强制抑制 JMS MQ 消息标头 MQRFH2（使用 targetClient MQ URL 选项值 1）。换句话说，我们想发送一个普通的 MQ 二进制消息（即只有 MQMD 消息描述符后跟有效负载）。
<camel:setHeader headerName="JMSReplyTo"><camel:constant>TEST.REPLYTOQ</camel:constant></camel:setHeader>
<camel:setHeader headerName="CamelJmsDestinationName"><camel:constant>queue://MYQMGR/TEST.Q2?targetClient=1</camel:constant></camel:setHeader>
更多 MQMD 字段可以通过reserved JMS properties 控制，如下图所示。请参阅 IBM 文档中的 restrictions。
<camel:setHeader headerName="JMS_IBM_Format"><camel:constant>MQSTR </camel:constant></camel:setHeader>
<camel:setHeader headerName="JMSCorrelationID"><camel:constant>_PLACEHOLDER_24_CHARS_ID_</camel:constant></camel:setHeader>
URI 中的目标队列被上面的 CamelJmsDestinationName 覆盖，因此 URI 中的队列名称成为占位符。
URI 选项 preserveMessageQos 是一个选项 - 正如观察到的那样 - 允许发送设置了回复数据的消息（以获取 MQ CoD 报告），但阻止 CAMEL 实例化回复消息侦听器通过执行 InOnly MEP。
<camel:to uri="wmq:queue:PLACEHOLDER.Q.NAME?concurrentConsumers=1&
exchangePattern=InOnly&preserveMessageQos=true&
includeSentJMSMessageID=true" />
</camel:route>
</camel:camelContext>
以下内容必须根据您的上下文进行调整。它为本地 JMS 提供者和 Websphere MQ（通过本地 IBM WMQ JCA 资源适配器）提供队列工厂。我们在这里使用 JNDI 查找管理对象。
<camel:endpoint id="innerQueue" uri="jmsloc:queue:transitQueue">
</camel:endpoint>
<jee:jndi-lookup id="mqQCFBean" jndi-name="jms/MYQMGR_QCF"/>
<jee:jndi-lookup id="jmsraQCFBean" jndi-name="jms/jmsra_QCF"/>
<bean id="jmsloc" class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFactory" ref="jmsraQCFBean" />
</bean>
<bean id="wmq" class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFactory" ref="mqQCFBean" />
</bean>
</beans>
或者，如果您使用 MQ 客户端 jars 而不是资源适配器，您将声明连接工厂 bean，如（代替上面的 JNDI 查找）：
<bean id="mqCFBean" class="com.ibm.mq.jms.MQXAConnectionFactory">
<property name="hostName" value="${mqHost}"/>
<property name="port" value="${mqPort}"/>
<property name="queueManager" value="${mqQueueManager}"/>
<property name="channel" value="${mqChannel}"/>
<property name="transportType" value="1"/> <!-- This parameter is fixed and compulsory to work with pure MQI java libraries -->
<property name="appName" value="${connectionName}"/>
</bean>
<bean id="wmq" class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFactory" ref="mqCFBean"/>
<property name="transacted" value="true"/>
<property name="acknowledgementModeName" value="AUTO_ACKNOWLEDGE"/>
</bean>
欢迎提出意见和改进。