From abd07dc172f22b2d772a84ba8f45b7499b663fea Mon Sep 17 00:00:00 2001
From: hongawen <83944980@qq.com>
Date: Fri, 18 Aug 2023 15:19:14 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=A4=84=E7=90=86=EF=BC=8C?=
 =?UTF-8?q?=E9=81=BF=E5=85=8D=E9=87=8D=E5=A4=8D=E5=BC=82=E5=B8=B8=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E5=85=A5=E5=BA=93?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/njcn/message/consumer/AppAutoDataConsumer.java     | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
index 4d15597..01d3975 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
@@ -105,8 +105,11 @@ public class AppAutoDataConsumer extends EnhanceConsumerMessageHandler<AppAutoDa
                 exceptionMsg = exceptionMsg.substring(0,180);
             }
             rocketmqMsgErrorLog.setRecord(exceptionMsg);
-            //单次消费异常
-            rocketMqLogFeignClient.add(rocketmqMsgErrorLog);
+            //如果是当前消息重试的则略过
+            if(!message.getSource().startsWith(EnhanceMessageConstant.RETRY_PREFIX)){
+                //单次消费异常
+                rocketMqLogFeignClient.add(rocketmqMsgErrorLog);
+            }
         } else {
             rocketmqMsgErrorLog.setRecord("重试消费" + super.getMaxRetryTimes() + "次，依旧消费失败。");
             //重试N次后，依然消费异常