From fb96268d7e9270f796bad7714431ec0bad72de02 Mon Sep 17 00:00:00 2001 From: eson <474420502@qq.com> Date: Mon, 13 Nov 2023 23:29:32 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E6=8E=89=E5=9E=83=E5=9C=BE=E6=95=B0?= =?UTF-8?q?=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.go | 4 +--- start_test.go | 1 - 2 files changed, 1 insertion(+), 4 deletions(-) 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) {