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

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