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 23:15:41 +08:00
parent 1713387f6d
commit 68787ed426
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
main.go
View File

@ -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)