diff --git a/internal/push/onlinepusher.go b/internal/push/onlinepusher.go index adeff3737..84b7f8af3 100644 --- a/internal/push/onlinepusher.go +++ b/internal/push/onlinepusher.go @@ -2,6 +2,7 @@ package push import ( "context" + "fmt" "github.com/openimsdk/protocol/msggateway" "github.com/openimsdk/protocol/sdkws" "github.com/openimsdk/tools/discovery" @@ -86,7 +87,8 @@ func (d *DefaultAllNode) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.M // Online push message for _, conn := range conns { - log.ZDebug(ctx, "get gateway conn detail ", "conn ", *conn) + fmt.Println(ctx, "get gateway conn detail ", "conn ", *conn) + conn := conn // loop var safe ctx := ctx wg.Go(func() error {