如何在ActiveMQ Artemis中查看消息messageId？QueueBrowser显示异常

可能原因 #

• 消息发送端手动将userId赋值给了JMSMessageID，违反JMS规范中消息ID由提供者自动生成的默认逻辑。
• 所使用的JMS服务器（如ActiveMQ、Artemis）存在特殊配置，导致消息ID被替换为用户标识。
• QueueBrowser获取的消息被代理类包装，调用getJMSMessageID时返回了错误的字段值。

排查与解决步骤 #

1. 检查消息发送代码
   确认发送消息时是否存在message.setJMSMessageID(userId)这类代码。JMS规范中，消息ID默认由服务端自动生成，手动设置会覆盖默认值，若存在此类逻辑，直接移除即可。

2. 核对JMS服务器配置
   查看JMS服务端的配置文件，排查是否有插件、扩展或配置项将用户ID映射为消息ID。比如部分提供商的自定义拦截器可能会修改消息属性，需确认并调整相关配置。

3. 打印消息全属性排查字段混淆
   修改代码打印消息的所有属性，明确JMSMessageID和自定义userId属性的实际值，避免字段混淆：

   messages.forEach(value -> {
       try {
           System.out.println("JMSMessageID: " + value.getJMSMessageID());
           // 遍历打印所有消息属性
           Enumeration<String> propNames = value.getPropertyNames();
           while (propNames.hasMoreElements()) {
               String name = propNames.nextElement();
               System.out.printf("%s: %s%n", name, value.getObjectProperty(name));
           }
       } catch (JMSException e) {
           throw new RuntimeException(e);
       }
   });
   

   通过输出对比，确认是否是误将自定义的userId属性当成了JMSMessageID。

4. 调整QueueBrowser的使用方式
   避免复用QueueBrowser实例，每次查询时创建新的浏览器，同时确认会话模式是否正确（非事务性会话无需额外提交即可获取最新消息）：

   // 每次查询创建新的QueueBrowser，关闭时自动释放资源
   try (QueueBrowser browser = queueSession.createBrowser(queue)) {
       Enumeration<Message> messageEnumeration = browser.getEnumeration();
       ArrayList<Message> messages = new ArrayList<>();
       while (messageEnumeration.hasMoreElements()) {
           messages.add(messageEnumeration.nextElement());
       }
       // 后续打印逻辑
   }
   

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