ActiveMQ设置JMSType后消费端获取为null问题求助

我来帮你排查这个问题——在ActiveMQ 5.15.3的点对点（Queue）场景下，调用setJMSType()后消费端拿到null确实是个常见的配置类坑，咱们一步步来解决：

核心原因 #

ActiveMQ默认对Queue消息做了优化，不会自动传递JMSType属性，这个属性在Topic场景下默认是生效的，但Queue场景需要额外配置来启用属性保留。

解决方案 #

方案1：修改生产者连接工厂配置 #

在创建ActiveMQConnectionFactory时，设置preserveMessageQos为true，这样生产者会强制发送所有消息属性（包括JMSType）：

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
connectionFactory.setPreserveMessageQos(true); // 关键配置
Connection connection = connectionFactory.createConnection();

这个配置会让生产者在发送Queue消息时，保留所有JMS标准属性，包括JMSType。

方案2：修改Broker端配置（全局生效） #

如果需要对所有Queue生效，可以修改ActiveMQ的activemq.xml配置文件，在<broker>标签内添加队列策略，开启属性保留：

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">
  <!-- 其他配置 -->
  <destinationPolicy>
    <policyMap>
      <policyEntries>
        <!-- 对所有Queue启用属性保留 -->
        <policyEntry queue=">" preserveMessageQos="true"/>
      </policyEntries>
    </policyMap>
  </destinationPolicy>
  <!-- 其他配置 -->
</broker>

修改后重启Broker，所有Queue消息都会保留JMSType属性。

方案3：手动添加自定义属性（备选） #

如果暂时无法修改配置，可以绕过JMSType，手动添加一个自定义属性来传递类型信息：

// 生产者端
TextMessage message = session.createTextMessage("Hello, this is my first message.");
message.setStringProperty("CustomJMSType", "Advisory");
producer.send(message);

// 消费端
TextMessage receivedMsg = (TextMessage) consumer.receive();
String type = receivedMsg.getStringProperty("CustomJMSType");

这种方式不需要依赖ActiveMQ的配置，兼容性更好，但需要修改生产者和消费端的代码。

验证步骤 #

1. 确保生产者代码中setJMSType()是在send()之前调用的，顺序不能错；
2. 消费端接收消息时，确认是从正确的Queue接收，没有订阅错误的目的地；
3. 配置修改后，重启Broker和生产者/消费者服务，避免缓存影响。

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