diff --git a/main.go b/main.go
index 5f403f7..0b910ff 100644
--- a/main.go
+++ b/main.go
@@ -138,13 +138,12 @@ 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)
+			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)