From 787815b64eda2048b722e64c81dcc62c7560e149 Mon Sep 17 00:00:00 2001
From: eson <474420502@qq.com>
Date: Mon, 13 Nov 2023 22:50:29 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=20=E8=A7=A6=E5=8F=91?=
 =?UTF-8?q?=E6=8F=90=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.go | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/main.go b/main.go
index 735d6b6..d82cdf9 100644
--- a/main.go
+++ b/main.go
@@ -138,13 +138,13 @@ func StartNode(cfg *ConfigServer) {
 	// 设置共享的参数
 	DequeueHandler.WithShared(nh)
 
-	go func() {
-		for DequeueHandler != nil {
-			DequeueHandler.Notify(DequeueHandler.NULL)
-			log.Println("DequeueHandler 触发")
-			time.Sleep(time.Second * 5)
-		}
-	}()
+	// go func() {
+	// 	for DequeueHandler != nil {
+	// 		DequeueHandler.Notify(DequeueHandler.NULL)
+	// 		log.Println("DequeueHandler 触发")
+	// 		time.Sleep(time.Second * 5)
+	// 	}
+	// }()
 
 	if err := nh.StartReplica(initialMembers, false, NewSMQueue, rc); err != nil {
 		fmt.Fprintf(os.Stderr, "failed to add cluster, %v\n", err)