如何通过CORE协议正确浏览ActiveMQ Artemis不同地址下的队列

问题原因 #

CORE协议的ActiveMQ JMS客户端默认会将队列名与同名地址绑定，当目标队列实际属于另一个地址（比如你场景中queue队列属于address地址）时，客户端会尝试在queue地址下创建该队列，而队列已经存在于address地址中，因此抛出ActiveMQQueueExistsException。AMQP协议客户端逻辑不同，找不到对应地址时会自动创建同名地址，导致多余地址生成。

解决方案 #

要直接通过CORE协议浏览目标队列且不生成多余地址，关键是显式指定队列所属的地址，有两种常用方式：

1. 使用完全限定队列名格式

创建JMS Queue对象时，采用队列名@地址名的格式，明确告知客户端队列归属的地址：

// 替换为你的队列名和地址名
Queue targetQueue = session.createQueue("queue@address");
QueueBrowser browser = session.createBrowser(targetQueue);

这种方式无需额外API转换，是最简便的通用写法。

2. 使用Artemis专属API指定地址和队列名

通过强转Session为ActiveMQSession，调用专属的createQueue方法直接指定地址、队列名：

ActiveMQSession amqSession = (ActiveMQSession) session;
// 参数依次为：地址名、队列名、是否持久化
Queue targetQueue = amqSession.createQueue("address", "queue", false);
QueueBrowser browser = amqSession.createBrowser(targetQueue);

这种方式更直观，适合需要精细控制队列属性的场景。

3. 可选：关闭客户端自动创建地址

为避免误创建多余地址，可在ActiveMQConnectionFactory中关闭自动创建地址的功能：

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
connectionFactory.setAutoCreateAddresses(false);

此配置会强制客户端仅使用已存在的地址，进一步提升严谨性。

验证效果 #

采用上述方式创建QueueBrowser后，客户端会直接关联到address地址下的queue队列，既不会抛出队列已存在的异常，也不会生成多余的queue地址，可正常浏览队列中的消息。

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