diff --git a/internal/push/onlinepusher.go b/internal/push/onlinepusher.go index a61399fb6..55b3ac481 100644 --- a/internal/push/onlinepusher.go +++ b/internal/push/onlinepusher.go @@ -87,12 +87,11 @@ func (d *DefaultAllNode) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.M // Online push message for _, conn := range conns { conn := conn // loop var safe - ctx := ctx wg.Go(func() error { msgClient := msggateway.NewMsgGatewayClient(conn) reply, err := msgClient.SuperGroupOnlineBatchPushOneMsg(ctx, input) if err != nil { - log.ZError(ctx, "SuperGroupOnlineBatchPushOneMsg ", err, "req:", input.String()) + log.ZError(ctx, "SuperGroupOnlineBatchPushOneMsg ", err, input.String()) return nil }