如何禁用ActiveMQ动态队列创建并在队列未显式创建时抛出异常？

默认情况下，ActiveMQ允许客户端动态创建队列——比如用JmsTemplate.convertAndSend()发消息到不存在的队列时，Broker会自动创建这个队列。要改成抛出异常，有两种实用方式：

1. 修改Broker配置，彻底禁用自动创建队列 #

这是最直接高效的方式，通过配置限制队列的自动创建行为：

• 打开ActiveMQ核心配置文件activemq.xml，找到<broker>标签下的<destinationPolicy>节点，添加或修改policyEntry：

  <destinationPolicy>
      <policyMap>
          <policyEntries>
              <!-- 对所有队列生效，关闭自动创建功能 -->
              <policyEntry queue=">" autoCreateQueues="false" />
          </policyEntries>
      </policyMap>
  </destinationPolicy>
  

  配置生效后，任何客户端尝试发送消息到未显式创建的队列时，都会直接抛出javax.jms.InvalidDestinationException异常。

• 如果需要更细粒度的权限控制（比如只允许特定用户创建队列），可以搭配安全插件：

  <plugins>
      <simpleAuthenticationPlugin>
          <users>
              <authenticationUser username="admin" password="admin" groups="admin" />
              <authenticationUser username="app-user" password="app-pass" groups="app" />
          </users>
      </simpleAuthenticationPlugin>
      <authorizationPlugin>
          <map>
              <authorizationMap>
                  <authorizationEntries>
                      <!-- 只有admin组能创建队列，app组只能读写已存在的队列 -->
                      <authorizationEntry queue=">" write="app" read="app" admin="admin" createQueuePermission="admin" />
                  </authorizationEntries>
              </authorizationMap>
          </map>
      </authorizationPlugin>
  </plugins>
  

  此时app-user尝试发消息到未配置的队列时，会因无创建权限抛出异常，而admin用户仍可正常创建队列。

2. 代码层面提前校验队列是否存在 #

如果无法修改Broker配置，也可以在发送消息前主动检查队列是否存在，比如用ActiveMQ专属API：

// 示例：发送前检查目标队列是否存在
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
try (Connection conn = factory.createConnection("app-user", "app-pass")) {
    conn.start();
    ActiveMQSession session = (ActiveMQSession) conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
    
    Queue targetQueue = session.createQueue("test-unconfigured-queue");
    ActiveMQDestination dest = (ActiveMQDestination) targetQueue;
    
    // 向Broker发送队列创建请求，若队列不存在会触发异常
    DestinationInfo destInfo = new DestinationInfo(conn, DestinationInfo.ADD_OPERATION, dest);
    conn.send(destInfo);
} catch (JMSException e) {
    // 捕获异常，说明队列未配置，直接抛出给上层处理
    throw new RuntimeException("目标队列未配置，请检查", e);
}

不过这种方式会多一次网络请求，性能不如Broker端配置高效，适合无法修改Broker配置的场景。

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