如何通过Spring Integration从WMQ获取JMS Destination（队列名称）

当然可以通过Spring Integration获取WMQ消息的来源队列名称！不过WMQ在JMS头信息的处理上和ActiveMQ有差异，得用它专属的属性来实现，下面给你几种可行的方式：

• 直接读取WMQ专有JMS属性
  WMQ会在消息中携带JMS_IBM_MQMD_QueueName属性，这个属性就存储了消息来源的队列名称。你可以在Spring Integration的消息处理逻辑中，从MessageHeaders里直接提取：

// 假设message是Spring Integration的Message对象
String sourceQueueName = message.getHeaders().get("JMS_IBM_MQMD_QueueName", String.class);

• 配置HeaderMapper保留厂商特定头
  默认情况下，Spring Integration的DefaultJmsHeaderMapper可能会过滤掉一些MQ厂商专属的头信息，所以你需要显式配置允许传递这些头：

@Bean
public DefaultJmsHeaderMapper wmqHeaderMapper() {
    DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
    // 允许所有入站和出站头，或者你可以精确指定需要的头
    mapper.setInboundHeaderNames("*");
    mapper.setOutboundHeaderNames("*");
    return mapper;
}

之后把这个mapper绑定到你的JMS消息驱动通道适配器或者消息网关中，确保WMQ的专属头能被正确传递到Spring Integration的消息头里。

• 注解驱动消费时直接注入头参数
  如果是用@JmsListener注解来消费消息，你可以直接在方法参数中通过@Header注解获取这个属性：

@JmsListener(destination = "your-consumer-queue")
public void processWmqMessage(Message<String> message,
                              @Header("JMS_IBM_MQMD_QueueName") String sourceQueue) {
    // 在这里使用sourceQueue变量，它就是消息来源的队列名称
    System.out.println("消息来自队列: " + sourceQueue);
}

需要注意的是，JMS_IBM_MQMD_QueueName是WMQ特有的属性，和ActiveMQ的JMSDestination不是同一个东西，所以不能直接复用ActiveMQ的代码逻辑。另外，确保你的WMQ客户端版本和Spring Integration的JMS模块版本兼容，避免出现属性无法读取的问题。

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