能否无需broker.xml文件在Reactive Messaging AMQP Connector中创建队列？

1. 利用Reactive Messaging配置自动声明队列 #

Quarkus的SmallRye AMQP Connector支持通过application.properties配置，让Broker自动创建队列并绑定到目标地址，完全不需要broker.xml。

生产者端配置 #

如果要发送消息到绑定了队列的地址，只需在生产者配置中指定队列参数：

# 生产者基础配置
mp.messaging.outgoing.my-producer.connector=smallrye-amqp
mp.messaging.outgoing.my-producer.address=my-target-address

# 自动创建并绑定队列
mp.messaging.outgoing.my-producer.queue.name=my-durable-queue
mp.messaging.outgoing.my-producer.queue.durable=true
mp.messaging.outgoing.my-producer.durable=true

配置中的queue.name会触发Broker自动创建对应队列，并绑定到address指定的地址；durable参数确保队列持久化，重启Broker后不会丢失。

消费者端配置 #

消费者侧同样可以自动触发队列创建，默认auto-declare为true，只需指定队列名称即可：

# 消费者基础配置
mp.messaging.incoming.my-consumer.connector=smallrye-amqp
mp.messaging.incoming.my-consumer.queue.name=my-durable-queue
mp.messaging.incoming.my-consumer.durable=true
# auto-declare默认开启，可省略显式配置
# mp.messaging.incoming.my-consumer.auto-declare=true

启动应用时，连接器会自动向Broker声明队列，若队列不存在则直接创建。

2. 通过AMQP客户端API动态创建队列 #

如果需要更灵活的队列管理（比如根据业务逻辑动态生成队列），可以使用Quarkus集成的AMQP客户端API直接调用Broker的管理能力：

import jakarta.enterprise.context.ApplicationScoped;
import io.smallrye.reactive.messaging.amqp.AmqpClient;
import io.vertx.amqp.AmqpQueueOptions;

@ApplicationScoped
public class DynamicQueueCreator {

    private final AmqpClient amqpClient;

    // 依赖注入AmqpClient
    public DynamicQueueCreator(AmqpClient amqpClient) {
        this.amqpClient = amqpClient;
    }

    public void createQueue(String queueName, String targetAddress) {
        AmqpQueueOptions queueOptions = new AmqpQueueOptions()
                .setDurable(true)
                .setAutoDelete(false);

        amqpClient.createQueue(queueName, targetAddress, queueOptions)
                .subscribe().with(
                        success -> System.out.printf("队列 %s 创建并绑定到地址 %s 成功%n", queueName, targetAddress),
                        error -> System.err.printf("队列创建失败: %s%n", error.getMessage())
                );
    }
}

可以在应用启动事件中调用该方法，或者根据业务触发队列创建。

3. Quarkus Dev Services的适配方式 #

对于Dev Services，上述两种方案都完全适用：

• 若使用配置自动声明，Dev Services启动的AMQP Broker会读取你的application.properties配置，自动创建对应的队列，无需额外传入broker.xml；
• 若使用动态API，Dev Services的Broker同样支持AMQP管理操作，代码逻辑无需修改即可运行。

你之前没找到对应的Dev Services配置，是因为Dev Services会自动复用Reactive Messaging的AMQP配置，不需要单独配置Broker的自定义文件。

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