rabbitmq:消费消息报错(AmqpException: PublisherCallbackChannel is closed)

rabbitmq:消费消息报错(AmqpException: PublisherCallbackChannel is closed)

错误日志:

org.springframework.amqp.AmqpException: PublisherCallbackChannel is closed

原因分析:消费消息返回ack默认是需要一秒内回复的,超时未返回则重新发送,导致重复消费

解决方案:设置initial-interval为合理值

spring:
  rabbitmq:
    listener:
      simple:
        acknowledge-mode: manual
        retry:
          #60秒后重试
          initial-interval: 60000 
          #启用发布重试
          enabled: true
          #传递消息的最大尝试次数
          max-attempts: 3 
          #尝试的最大时间间隔
          max-interval: 60000 
          #应用于先前传递重试时间间隔的乘数
          multiplier: 1.0
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。
禁止转载,如需转载请通过简信或评论联系作者。

相关阅读更多精彩内容

友情链接更多精彩内容