From ba33f9abb6d0712c1b0e724064d16aaffd537994 Mon Sep 17 00:00:00 2001
From: lijiayao <13831655+xiao-yao-charge-forward@user.noreply.gitee.com>
Date: Sat, 6 Apr 2024 10:47:14 +0800
Subject: [PATCH 1/2] =?UTF-8?q?fix:=20=E4=BB=A3=E7=A0=81=E4=B8=A2=E5=A4=B1?=
 =?UTF-8?q?=E6=89=BE=E5=9B=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/couplet/analyze/msg/model/ModelMessage.java   | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java
index d621580..9d911e9 100644
--- a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java
+++ b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java
@@ -110,11 +110,12 @@ public class ModelMessage {
                             IncidentService incidentService = SpringUtils.getBean(string);
                             incidentService.incident(msgData);
                         }
-                        try {
-                            Thread.sleep(1000);
-                        } catch (InterruptedException e) {
-                            throw new RuntimeException(e);
-                        }
+//                        不睡眠，他们也会主动拉取数据，不会影响其他服务
+//                        try {
+//                            Thread.sleep(1000);
+//                        } catch (InterruptedException e) {
+//                            throw new RuntimeException(e);
+//                        }
                     }
 
                 }

From 5184d5740717cbd22828ab06ff599f3506809858 Mon Sep 17 00:00:00 2001
From: lijiayao <13831655+xiao-yao-charge-forward@user.noreply.gitee.com>
Date: Sat, 6 Apr 2024 10:55:51 +0800
Subject: [PATCH 2/2] =?UTF-8?q?fix:=20=E4=BB=A3=E7=A0=81=E4=B8=A2=E5=A4=B1?=
 =?UTF-8?q?=E6=89=BE=E5=9B=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/couplet/analyze/msg/consumer/FenceConsumer.java     | 1 -
 1 file changed, 1 deletion(-)

diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/consumer/FenceConsumer.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/consumer/FenceConsumer.java
index 828df61..4e858d4 100644
--- a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/consumer/FenceConsumer.java
+++ b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/consumer/FenceConsumer.java
@@ -68,7 +68,6 @@ public class FenceConsumer {
                 log.error("消息已丢失,已再次传入的信息是:【{}】", fenceUpdateRequest);
                 channel.basicNack(deliveryTag, true, false);
             }
-
         }