如何使用Apache Camel-JMS设置JMS_IBM_MQMD_MsgId消息头？

核心问题在于两点：

• IBM MQ强制要求JMS_IBM_MQMD_MsgId必须以**字节数组（byte[]）**类型设置
• Apache Camel默认的JmsBinding会过滤非基本类型的Header，导致字节数组属性被忽略

以下是两种可行的解决方案：

方案1：直接操作IBM原生JMS消息对象 #

绕过Camel的Header处理逻辑，直接创建并配置IBM原生JMS消息实例：

from("direct:sendToMQ")
    .process(exchange -> {
        // 获取ConnectionFactory并创建IBM原生JMS消息
        JmsConnectionFactory connFactory = exchange.getContext().getRegistry()
                .lookupByName("jmsConnectionFactory", JmsConnectionFactory.class);
        JmsTextMessage mqMessage = (JmsTextMessage) connFactory.createConnection()
                .createSession(false, Session.AUTO_ACKNOWLEDGE)
                .createTextMessage(exchange.getIn().getBody(String.class));
        
        // 自定义MessageID：将字符串转为字节数组
        String customMsgId = "ID:TESTYTEST";
        mqMessage.setObjectProperty("JMS_IBM_MQMD_MsgId", customMsgId.getBytes(StandardCharsets.UTF_8));
        
        // 同时设置其他MQMD属性（如已正常工作的ApplIdentityData）
        mqMessage.setStringProperty("JMS_IBM_MQMD_ApplIdentityData", "testApp");
        
        exchange.getIn().setBody(mqMessage);
    })
    .to("jms:queue:YOUR_QUEUE_NAME?connectionFactory=#jmsConnectionFactory");

注意：你已配置的WMQConstants.WMQ_MQMD_WRITE_ENABLED=true必须保留，这是启用MQMD属性写入的前提。

方案2：自定义Camel JmsBinding，允许字节数组Header #

修改Camel的JmsBinding逻辑，让它允许传递JMS_IBM_MQMD_前缀的字节数组属性：

// 自定义JmsBinding类
public class CustomMqJmsBinding extends JmsBinding {
    public CustomMqJmsBinding(JmsEndpoint endpoint) {
        super(endpoint);
    }

    @Override
    protected void setJmsHeader(Message jmsMessage, String headerName, Object headerValue) throws JMSException {
        // 对IBM MQMD属性直接放行，不做类型过滤
        if (headerName.startsWith("JMS_IBM_MQMD_")) {
            jmsMessage.setObjectProperty(headerName, headerValue);
        } else {
            super.setJmsHeader(jmsMessage, headerName, headerValue);
        }
    }
}

然后在配置JMS Endpoint时绑定这个自定义Binding：

JmsEndpoint mqEndpoint = context.getEndpoint("jms:queue:YOUR_QUEUE_NAME", JmsEndpoint.class);
mqEndpoint.setBinding(new CustomMqJmsBinding(mqEndpoint));

之后就可以正常用setHeader设置字节数组了：

from("direct:sendToMQ")
    .setHeader("JMS_IBM_MQMD_MsgId", constant("ID:TESTYTEST".getBytes(StandardCharsets.UTF_8)))
    .setHeader("JMS_IBM_MQMD_ApplIdentityData", constant("testApp"))
    .to("jms:queue:YOUR_QUEUE_NAME?connectionFactory=#jmsConnectionFactory");

额外注意事项 #

• MQ的MsgId字段最大长度为24字节，自定义字符串转字节后若超过该长度，可能会被截断或触发报错，建议控制内容长度
• 确保IBM MQ客户端版本与Camel JMS组件版本兼容，避免API差异导致的问题

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