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);
    }
}

  


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM