diff --git a/main.go b/main.go index ad706fe..43f44fb 100644 --- a/main.go +++ b/main.go @@ -9,6 +9,7 @@ import ( "path/filepath" "runtime" "syscall" + "time" "github.com/474420502/execute/triggered" "github.com/lni/dragonboat/v4" @@ -31,6 +32,7 @@ var DequeueHandler = triggered.RegisterExecute(func(params *triggered.Params[boo break } if item == nil { + time.Sleep(time.Millisecond * 100) return } diff --git a/sm_upate_handler.go b/sm_upate_handler.go index 0850d19..85fe0e2 100644 --- a/sm_upate_handler.go +++ b/sm_upate_handler.go @@ -12,6 +12,7 @@ import ( var FsPasser *passer.Passer[sm.Result] = func() *passer.Passer[sm.Result] { fsPasser := passer.NewPasser[sm.Result]() + fsPasser.RegisterPasser(&CmdEnqueue{}, func(cxt context.Context, obj any) (sm.Result, error) { var smqueue = cxt.Value(ctxSMQueue{}).(*SMQueue) diff --git a/websocket_test.go b/websocket_test.go index 6e8f754..09412e9 100644 --- a/websocket_test.go +++ b/websocket_test.go @@ -38,8 +38,9 @@ func TestWebsocketC(t *testing.T) { fusenrender.StartNode(svc) } -// var addr = "api.fusen.3718.cn:4050" -var addr = "localhost:4050" +var addr = "api.fusen.3718.cn:4050" + +// var addr = "localhost:4050" func TestWebsocketCient(t *testing.T) { // u := url.URL{Scheme: "ws", Host: addr, Path: "/ws/pop/queue"}