嵌入式ActiveMQ Artemis接收管理消息失败，无法跟踪临时队列创建

你遇到的核心问题是未正确注册管理事件订阅，同时可能存在嵌入式Broker配置缺失、临时队列创建逻辑不明确的问题，以下是具体的排查和修复步骤：

1. 必须显式注册管理事件订阅 #

Artemis不会主动将所有管理事件推送到activemq.management地址，需要你通过管理API主动订阅感兴趣的事件类型（比如临时队列的创建/销毁）。同时你当前的代码未启动会话，导致Consumer无法接收消息。

修改你的Java代码如下：

ServerLocator locator = ActiveMQClient.createServerLocator("vm://0");
locator.setMinLargeMessageSize(6291456);

ClientSessionFactory clientSessionFactory = locator.createSessionFactory();
session_ = clientSessionFactory.createSession(false, true);

// 创建管理事件消费者
ClientConsumer notificationConsumer = session_.createConsumer("activemq.management");
notificationConsumer.setMessageHandler(new MessageHandler() {
  @Override
  public void onMessage(ClientMessage clientMessage) {
    try {
      // 解析管理通知的关键信息
      String eventType = ManagementHelper.getNotificationType(clientMessage);
      Map<String, Object> eventProps = ManagementHelper.getNotificationProperties(clientMessage);
      log_.info(">>> Received notification: {} | Details: {}", eventType, eventProps);
    } catch (Exception e) {
      log_.error("Failed to parse management notification", e);
    }
  }
});

// 注册订阅临时队列的创建/销毁事件
ClientMessage registerMsg = session_.createMessage(false);
ManagementHelper.putOperationInvocation(
  registerMsg,
  "broker",
  "addNotificationListener",
  "activemq.management",
  null, // 无过滤条件，监听所有指定类型事件
  new String[]{"QUEUE_CREATED", "QUEUE_DELETED"}
);
session_.send("activemq.management", registerMsg);

// 启动会话，否则Consumer无法接收消息
session_.start();

2. 确保嵌入式Broker启用管理通知 #

检查你的broker.xml，确认已配置管理插件并启用所需的通知类型：

<management-plugin>
  <class-name>org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl</class-name>
  <configuration>
    <notification-broadcast-period>1000</notification-broadcast-period>
    <notification-types>
      <type>QUEUE_CREATED</type>
      <type>QUEUE_DELETED</type>
    </notification-types>
  </configuration>
</management-plugin>

你的management-address及对应队列配置是正确的，需确认嵌入式Broker启动时已加载该配置文件。

3. 验证Python客户端的临时队列创建逻辑 #

Stomp协议中，Artemis会自动为订阅/temp-queue/xxx的客户端创建临时队列，但需注意：

• 临时队列的QUEUE_CREATED事件中，queueType属性会标记为TEMPORARY，你可以在通知解析时过滤该属性，只关注临时队列。
• 若客户端未保持连接，临时队列会被自动销毁，触发QUEUE_DELETED事件。

4. 额外检查点 #

• 确保嵌入式Broker启动时未禁用管理功能，比如启动参数中没有-Dactivemq.management.disable=true。
• 查看Artemis日志，确认管理插件已正常加载，无相关错误信息。

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