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)