我们正尝试在spring boot应用程序中使用spring-rabbit来创建一个消息侦听器。但是,我们在接收消息的过程中遇到了一个问题,如果队列不存在,应用程序就会抛出一个错误,称为被动声明。
Channel error on connection (172.13.1.3:49352 -> 172.13.1.7:5672, vhost: '/', user: 'guest'), channel 1:
message_queue_1_1 | operation queue.declare caused a channel exception not_found: no queue 'add' in vhost '/'我们想要的是主动声明一个队列,即如果队列不存在,则应该在mq中声明它。
发布于 2018-07-26 19:44:12
要从应用程序自动在代理上声明AMQP对象,您确实需要将它们配置为bean,并且还需要一个特殊的AmqpAdmin bean来执行硬声明逻辑。文档包含了所有必需的解释:https://docs.spring.io/spring-amqp/docs/2.0.4.RELEASE/reference/html/_reference.html#broker-configuration
https://stackoverflow.com/questions/51533401
复制相似问题