-
Notifications
You must be signed in to change notification settings - Fork 14.4k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
rabbitmq报错acknowledge-mode: manual配置不生效 #6188
Comments
版本号多少? |
版本号是3.6.3 不知道是不是没安装rabbitmq_delayed_message_exchange插件的原因, centos7.9的系统试了好几种方法都没安装上这个插件 所以少了jeecg.delayed.exchange |
初始化队列的时候ackmode没带上 是这个原因吗 |
|
延迟队列必须安装 |
zj |
根本原因为进行了double ack,jeecg-starter-rabbitmq在代码中已经进行了手动ack,但如果用户再次进行手动ack就会导致该错误。 解决办法:去除手动ack的代码即可 |
版本号:spring3版本 项目地址是https://github.com/jeecgboot/jeecg-boot
分支:
master
问题描述:
使用rabbitmq的 消费端手动ack消息,nacos配置已修改为acknowledge-mode: manual,但是使用channel.basicAck(deliveryTag, false);手动ack消息的时候报错,好像是manual配置没生效或者被覆盖掉了
报错信息如下:
2024-04-28 13:33:00.969 [http-nio-7001-exec-3] INFO o.j.boot.starter.rabbitmq.client.RabbitMqClient:203 - 发送消息到mq
2024-04-28 13:33:01.147 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#1-2] INFO org.jeecg.modules.system.listener.PicQueueListener:35 - [图像识别算法处理器] deviceCode:DWQ001,deviceCode1:,requestString:req,parkingString:parking
2024-04-28 13:33:01.153 [AMQP Connection 115.216.25.87:5672] ERROR o.s.a.rabbit.connection.CachingConnectionFactory:752 - Shutdown Signal: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80)
2024-04-28 13:33:02.151 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#1-2] INFO o.s.a.r.listener.SimpleMessageListenerContainer:1463 - Restarting Consumer@efbdd39: tags=[[amq.ctag-DjCbbXdjn4mOntf_ICkMFA]], channel=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(amqp://dingqi@115.216.25.87:5672/,7), conn: Proxy@7239f4ba Shared Rabbit Connection: SimpleConnection@64c457f0 [delegate=amqp://dingqi@115.216.25.87:5672/, localPort= 31367], acknowledgeMode=AUTO local queue size=0
截图&代码:
The text was updated successfully, but these errors were encountered: