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