RABBITMQ的Spring -AMQP实施 - 它在内部使用Queuedeclarepassive吗？

Question

我们从现有的经典队列迁移到法定人数，其中之一是我们必须将队列用法宣布为“被动”（即QueuedeclarePassive）。目的是确保我们不会动态创建任何队列，而只检查其存在（如果不存在，则失败）然后连接。

我们有一项使用Spring-AMQP的旧服务，我们将SimpleMessageListenerContainer设置为这样：

SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setQueueNames(queue().getName());

...

public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
    RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
    rabbitTemplate.getConnectionFactory().createConnection().createChannel(false);
    return rabbitTemplate;
}

我看不到将队列声明为“被动”的方法。在阅读spring.io文档时，我看到了声明的描述：

“被动队列声明失败时重试的尝试数量。当消费者启动消费者或从多个队列中消费时，就会发生被动队列声明，当并非所有队列都可以在多个队列中消费时初始化。”

这是否意味着Spring-AMQP在幕后使用queuedeclarepassive？这是否在任何地方都有明确的记录？如果我不正确，如何在此AMQP使用中正确确保使用queuedeclarepassive？

提前致谢！

Answer 1

这是否暗示Spring-AMQP在幕后使用Queuedeclarepassive？

它不是暗示它明确说明它。

queuedeclarepassive在启动过程中使用了侦听器容器，以验证已配置的队列。

默认情况下，SimpleMessageListenerContainer将以5秒的间隔尝试3次，如果被动声明失败，则容器将停止。可以配置尝试和间隔的数量。

DirectMessageListEnerContainer使用其Monitor> Monitor> Monitor> Monitalval属性，将无限期地尝试被动声明队列。

Spring AMQP仅执行非邮局队列声明（队列创建），如果应用程序上下文包含Queue @Bean s，并且有一个Rabbitadmin < < 代码> @bean 存在。