diff --git a/main.go b/main.go index 0b910ff..f0b228f 100644 --- a/main.go +++ b/main.go @@ -21,12 +21,10 @@ var shardID uint64 = 128 // 出队的逻辑注册触发函数, 当 var DequeueHandler = triggered.RegisterExecute(func(params *triggered.Params[bool]) { - log.Println("DequeueHandler 触发数据") - params.Shared.Value(func(v any) { + params.Shared.Value(func(v any) { cs := stateClient.GetNoOPSession() for { - item, err := stateClient.PopItem(cs, "unity3d") if err != nil { log.Println(err) diff --git a/start_test.go b/start_test.go index fbcbc3c..3458ce0 100644 --- a/start_test.go +++ b/start_test.go @@ -6,7 +6,6 @@ import ( func init() { log.SetFlags(log.Llongfile) - } // func TestStartNodeA(t *testing.T) {