fusen/fusen-render
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

删除 触发提示

Browse Source
This commit is contained in:
eson 2023-11-13 22:50:29 +08:00
parent e1162c6a47
commit 787815b64e
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
main.go
View File

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