Apache Camel结合IBM MQ如何设置ReplyToQMgr、ReplyToQ接收COA

核心配置修正 #

• 首先开启IBM MQ相关头的透传能力：在Camel的IBM MQ组件/JMS组件配置中添加allowedHeaders参数，值设置为JMS_IBM_*，或者直接配置为*允许所有头透传，避免JMS_IBM_MQMD_xxx系列头被默认过滤。
  示例Spring Boot配置：

camel.component.jms.allowed-headers=JMS_IBM_*

如果是代码配置：

JmsComponent ibmMqComponent = new JmsComponent();
ibmMqComponent.setAllowedHeaders("JMS_IBM_*");
camelContext.addComponent("ibmmq", ibmMqComponent);

• 正确设置JMSReplyTo对象：不要直接传入字符串格式的队列地址，而是通过IBM MQ JMS API创建MQQueue对象，同时指定回复队列和回复队列管理器：

MQQueue replyQueue = (MQQueue) session.createQueue("reply-to-q");
replyQueue.setBaseQueueManagerName("QMGR_REM");
exchange.getIn().setJMSReplyTo(replyQueue);

• 显式设置COA报告标识：在消息头中添加JMS_IBM_MQMD_Report参数，值设置为MQRO_COA（对应数值16，可直接传入整数），通知IBM MQ生成送达确认报文。

exchange.getIn().setHeader("JMS_IBM_MQMD_Report", 16);

常见踩坑补充 #

• 如果使用的是Camel IBM MQ专用组件，需要额外开启mdMessageContext参数为true，确保MQMD上下文会被保留传递。
• 若仍然出现回复队列被截断的问题，可跳过字符串格式的ReplyTo设置，直接通过JMS_IBM_MQMD_ReplyToQ和JMS_IBM_MQMD_ReplyToQMgr两个头分别指定回复队列名称和回复队列管理器名称，优先级高于JMSReplyTo对象的解析结果。

内容的提问来源于stack exchange，提问作者olezhka