java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > SpringBoot集成RbbitMQ队列踩坑

SpringBoot集成RbbitMQ队列踩坑记录

作者:偷代码的猫

这篇文章主要介绍了SpringBoot集成RbbitMQ队列踩坑记录,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

找不到队列

2019-07-03 13:11:11.106  WARN 11944 --- [cTaskExecutor-1] o.s.a.r.listener.BlockingQueueConsumer   : Failed to declare queue: hello
2019-07-03 13:11:11.118  WARN 11944 --- [cTaskExecutor-1] o.s.a.r.listener.BlockingQueueConsumer   : Queue declaration failed; retries left=3
 
org.springframework.amqp.rabbit.listener.BlockingQueueConsumer$DeclarationException: Failed to declare queue(s):[hello]

解决办法1

在页面客户端手动创建所需队列

解决办法2

使用代码自动创建

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
 
/**
 * 消息队列配置类,创建消息队列
 * 路由秘钥为hello
 */
@Configuration
public class RbbitConfig {
 
    @Bean
    public Queue messageQueue(){
        return new Queue("hello1");
    }
}

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

您可能感兴趣的文章:
阅读全文