From 85522652200c32fcfb721d2df5b01c7138f31139 Mon Sep 17 00:00:00 2001 From: liuxiaobo <1224730913@qq.com> Date: Thu, 29 May 2025 11:56:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=B5=8B=E8=AF=95=E9=94=99?= =?UTF-8?q?=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- service/natsService_test.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/service/natsService_test.go b/service/natsService_test.go index d199b4f..571d4eb 100644 --- a/service/natsService_test.go +++ b/service/natsService_test.go @@ -2,6 +2,7 @@ package service import ( "fmt" + "github.com/fox/fox/ipb" "github.com/fox/fox/log" "testing" "time" @@ -76,8 +77,8 @@ func (s *gameService) OnMessage(msg []byte) error { func TestGameService(t *testing.T) { log.Open("test.log", log.DebugL) s := newGameService() - msg := "hello world" - if err := s.Send(Topic(s), []byte(msg)); err != nil { + msg := ipb.MakeMsg(GameSrv, 0, 1, 2, []byte("hello world")) + if err := s.Send(Topic(s), msg); err != nil { log.Error(err.Error()) } s.GetServiceNodes().Range(func(key, value interface{}) bool {