BlockingQueueConsumer$DeclarationException: Failed to declare queue(s)：xxxx；创建队列异常

时间：2020-07-01 15:36:43 收藏：0 阅读：1360

BlockingQueueConsumer$DeclarationException: Failed to declare queue(s):xxxx；出现这个问题是因为没有声明队列就在项目中使用队列了，所以应该先在包下创建一个配置类，并声明队列，放到IOC容器中

@Configuration
//创建MQ队列
public class MQconfig {
@Bean
    public Queue queueOrder(){
        return new Queue("order_queue", true);
    }
@Bean
    public Queue queueOrderStatus(){
        return new Queue("order_status_queue", true);
    }
}

原文：https://www.cnblogs.com/zwwang/p/13219336.html