使用Spring Integration消费IBM MQ时获取JMS Destination/队列名

这是IBM MQ JMS客户端和Spring Integration配合时的典型坑——IBM MQ的JMS实现默认不会在消息头中自动填充JMSDestination属性，而ActiveMQ是默认开启这个行为的。下面给你几个实用的解决办法：

方法1：开启IBM MQ连接工厂的Destination头传递属性 #

IBM MQ提供了专属配置，开启后会在发送消息时把Destination信息写入JMS头，消费端就能正常获取JMSDestination了。

如果是Java代码配置连接工厂：

@Bean
public MQQueueConnectionFactory mqQueueConnectionFactory() {
    MQQueueConnectionFactory factory = new MQQueueConnectionFactory();
    // 配置你的MQ基础连接信息：主机、端口、队列管理器、通道等
    factory.setHostName("your-mq-host");
    factory.setPort(1414);
    factory.setQueueManager("QMGR");
    factory.setChannel("SYSTEM.DEF.SVRCONN");
    
    // 关键配置：开启JMS Destination头传递
    factory.setBooleanProperty(WMQConstants.WMQ_SET_JMS_DESTINATION_HEADER, true);
    return factory;
}

如果是Spring Boot用户，直接在配置文件里设置更简洁：

# application.properties
ibm.mq.jms.set-destination-header=true

方法2：从IBM MQ专属消息属性获取队列名 #

如果没办法修改连接工厂配置（比如用的是第三方提供的连接池），可以直接读取IBM MQ消息头里的专属属性JMS_IBM_MQMD_DestQ，它存储了目标队列的名称：

@ServiceActivator(inputChannel = "mqInputChannel")
public void processMqMessage(Message<?> message) {
    // 从消息头中提取IBM MQ专属的队列名属性
    String targetQueueName = message.getHeaders().get("JMS_IBM_MQMD_DestQ", String.class);
    // 你的业务处理逻辑
    System.out.println("当前消费的队列：" + targetQueueName);
}

为什么只有IBM MQ会出现这个问题？ #

IBM MQ默认关闭JMSDestination头的传递是出于性能优化考虑——额外的头信息会增加消息的大小；而ActiveMQ默认开启了这个特性，所以你在ActiveMQ上能正常拿到该属性。

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