RabbitMq从入门到精通- reply-code=406, reply-text=PRECONDITION_FAILED
[WARN ] 2020-05-07 09:53:32,699 [SimpleAsyncTaskExecutor-20] o.s.a.r.l.SimpleMessageListenerContainer - Consumer raised exception, processing can restart if the connection factory supports it
com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80)
at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:505)
at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:336)
at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:143)
at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:90)
at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:634)
at com.rabbitmq.client.impl.AMQConnection.access$300(AMQConnection.java:47)
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:572)
at java.lang.Thread.run(Thread.java:748)
channel.basicAck(deliveryTag,false);
-
rabbitmq:
-
host: 192.168.0.222
-
port: 5672
-
username: test
-
password: test
-
publisher-confirms: true
-
virtual-host: /
-
listener:
-
simple:
-
acknowledge-mode: manual
-
concurrency: 10 # 消费者数量
-
max-concurrency: 10 # 消费者最大数量
-
prefetch: 1 # 消费者每次从队列中取几个消息
-
auto-startup: true # 启动时自动启动消费者
-
default-requeue-rejected: true # 消息消费失败后,重新进入消费队列中
-
retry:
-
enabled: true # 启用发布重试
-
initial-interval: 1000 # 1秒后重试
-
max-attempts: 3 # 传递消息的最大尝试次数
-
max-interval: 10000 # 尝试的最大时间间隔
-
multiplier: 1.0 # 应用于先前传递重试时间间隔的乘数
注释掉
文章来源: blog.csdn.net,作者:隔壁老瓦,版权归原作者所有,如需转载,请联系作者。
原文链接:blog.csdn.net/wxb880114/article/details/105966144
- 点赞
- 收藏
- 关注作者
评论(0)