rabbitmq:消費消息報錯(AmqpException: PublisherCallbackChannel is closed)

rabbitmq:消費消息報錯(AmqpException: PublisherCallbackChannel is closed)

錯誤日志:

org.springframework.amqp.AmqpException: PublisherCallbackChannel is closed

原因分析:消費消息返回ack默認是需要一秒內回復的,超時未返回則重新發(fā)送,導致重復消費

解決方案:設置initial-interval為合理值

spring:
  rabbitmq:
    listener:
      simple:
        acknowledge-mode: manual
        retry:
          #60秒后重試
          initial-interval: 60000 
          #啟用發(fā)布重試
          enabled: true
          #傳遞消息的最大嘗試次數
          max-attempts: 3 
          #嘗試的最大時間間隔
          max-interval: 60000 
          #應用于先前傳遞重試時間間隔的乘數
          multiplier: 1.0
?著作權歸作者所有,轉載或內容合作請聯系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內容(如有圖片或視頻亦包括在內)由作者上傳并發(fā)布,文章內容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。
禁止轉載,如需轉載請通過簡信或評論聯系作者。

相關閱讀更多精彩內容

友情鏈接更多精彩內容