如何通过Core API修改ActiveMQ Artemis队列的路由类型

报错原因 #

你收到AMQ229069: no operation updateQueue/1错误有两个核心原因：

• 调用的管理资源对象错误：updateQueue不是队列级别的管理操作，是Broker根管理对象的操作，你把操作请求发送到了testQueue队列的管理资源上，自然找不到对应方法
• ActiveMQ Artemis 2.17.0版本的updateQueue管理方法根本没有单参数的重载，该版本的updateQueue需要传入队列名、过滤器、最大消费者数等多个独立参数，不支持直接传入QueueConfiguration的JSON串

核心限制说明 #

ActiveMQ Artemis设计上不支持直接修改已存在队列的路由类型，路由类型是队列创建时的核心元属性，修改会影响已有的地址路由规则、消费者绑定、已落地消息的分发逻辑，因此不管是Core API还是管理API，都没有提供直接修改队列路由类型的能力。
你观察到ClientSession只提供createQueue、deleteQueue方法也是因为这个设计逻辑。

可行解决方法 #

你可以通过「删除旧队列-重建新队列」的方式实现路由类型修改，操作前请确保旧队列的消息已经被消费、备份，或你可以接受消息丢失：

示例代码（Core API方式） #

import org.apache.activemq.artemis.api.core.RoutingType;
import org.apache.activemq.artemis.api.core.client.ClientSession;
import org.apache.activemq.artemis.api.core.client.ClientSessionFactory;
import org.apache.activemq.artemis.api.core.client.ActiveMQClient;
import org.apache.activemq.artemis.api.core.QueueConfiguration;

public class UpdateQueueRoutingType {
    public static void main(String[] args) throws Exception {
        // 连接broker，替换为你的实际连接参数
        try (ClientSessionFactory factory = ActiveMQClient.createClientSessionFactory("tcp://localhost:61616");
             ClientSession session = factory.createSession("admin", "admin", false, true, true, false, 1)) {
            
            String queueName = "testQueue";
            // 1. 删除原有队列
            session.deleteQueue(queueName);
            // 2. 用新的路由类型重建队列
            QueueConfiguration newQueueConfig = new QueueConfiguration(queueName)
                    .setAddress("testQueue")
                    .setRoutingType(RoutingType.MULTICAST)
                    .setAutoCreateAddress(true)
                    .setDurable(true); // 根据你的需求调整其他属性
            session.createQueue(newQueueConfig);
            
            session.commit();
        }
    }
}

消息不丢失的补充操作 #

如果需要保留旧队列的消息，可以在删除队列前先：

• 创建一个临时队列
• 使用Core API的队列浏览功能，把旧队列的所有消息转发到临时队列
• 重建目标队列后，再把临时队列的消息转发回新队列
• 删除临时队列

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