Spring AMQP 发送消息到 RabbitMQ 收到 x-queue-type 错误
2024-10-15 10:22:56
在使用 Spring AMQP 发送消息到 RabbitMQ 的时候收到错误信息:
inequivalent arg 'x-queue-type' for queue 'com.ossez.real.estate' in vhost '/': received none but current is the value 'classic' of type 'longstr', class-id=50, method-id=10
上面的错误信息已经很明显了,说明的是发送消息的队列参数中少了 x-queue-type 这个参数。
在代码中,我们创建队列的参数为:
return new Queue(MY_QUEUE_NAME, NON_DURABLE);
这直接创建队列的参数少了 args.put("x-queue-type", "classic");
因此,我们需要在创建队列的时候添加上面的参数。
修改代码为:
Map<String, Object> args = new HashMap<>();
// // set the queue with a dead letter feature
args.put("x-queue-type", "classic");
return new Queue(MY_QUEUE_NAME, NON_DURABLE, false, false, args);
请参考 GitHub 中的代码:
https://blog.ossez.com/archives/3050
最新文章
- ERROR 2002 (HY000): Can't connect to local MySQL server through socket '/var/lib/mysql/mysql.sock' (2)
- 前端学习实践笔记--JavaScript深入【2】
- EMIF接口的寻址问题
- lvs之dr技术的学习与实践
- vsftpd2.3.2安装、配置详解
- CentOS6.5下用yum安装 git
- BZOJ 1004 Cards(Burnside引理+DP)
- 通过物理模型生成Java代码
- 【转】Java 工程师成神之路
- cssText笔记
- JAVA中获取文件MD5值的四种方法
- MySQL基本应用
- Deadlock found when trying to get lock; try restarting transaction
- [LeetCode] Shortest Distance to a Character 到字符的最短距离
- centos部署redis主从
- 通过set-context 控制namespace 进行隔离
- C. Books Queries
- Android接入微信SDK之一:发起微信授权登录
- Python中__init__()方法注意点
- 原生js--应用程序存储和离线web应用
热门文章
- Python3 + selenium + Chrome浏览器(webdriver.Chrome()报错)
- 关于greenlet的一些问题
- 3.解决git不可用问题
- kubernetes 健康检查和初始化容器
- go环境变量配置 (GOROOT和GOPATH)的区别和含义
- 超详细,新手都能看懂 !使用SpringBoot+Dubbo 搭建一个简单的分布式服务
- c# redis密码验证笔记
- asp.net core In Docker(Image)
- ECharts简单入门demo
- TimeUtil 工具类