使用 args 创建 SpringAMQP 队列

SpringAMQP Queue creation with args

我创建了一个带有消息过期参数的队列,但在启动服务器时出现以下错误。

[SimpleAsyncTaskExecutor-1] o.s.a.r.c.RabbitAdmin [RabbitAdmin.java:375] Auto-declaring a non-durable Queue (TEST_QUEUE). It will be redeclared if the broker stops and is restarted while the connection factory is alive, but all messages will be lost.
pool-1-thread-1] o.s.a.r.c.CachingConnectionFactory [CachingConnectionFactory.java:249] Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'durable' for queue 'EXP_MSG' in vhost '/': received 'false' but current is 'true', class-id=50, method-id=10)
ERROR [SimpleAsyncTaskExecutor-1] o.s.a.r.l.SimpleMessageListenerContainer [SimpleMessageListenerContainer.java:914] Failed to check/redeclare auto-delete queue(s).
org.springframework.amqp.AmqpIOException: java.io.IOException
    at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:63) ~[spring-rabbit-1.4.0.RELEASE.jar:na]
    at org.springframework.amqp.rabbit.connection.RabbitAccessor.convertRabbitAccessException(RabbitAccessor.java:110) ~[spring-rabbit-1.4.0.RELEASE.jar:na]

我使用 Spring boot 1.2.8 和 Spring 4.2.5 版本。

   @Bean
    Queue expiredMessageQueue() {
        Map args = new HashMap();
        args.put("x-message-ttl", 60000);
        return new Queue(expiredMessageQueue, false, false, false,args);
    }

inequivalent arg 'durable' for queue 'EXP_MSG' in vhost '/': received 'false' but current is 'true'

这意味着 RabbitMQ Broker 上已经存在这样的队列,但具有不同的属性。

如果您想更改它并通过应用程序重新创建,您应该在启动应用程序之前先将其从 Broker 中删除。或者将所有选项与现有选项对齐。

那叫像passiveDeclaration。侦听器确实需要一个真正的队列来订阅,只有 why 方法来检查它是否存在所需的状态,尝试在侦听器启动期间声明它。