From 9543cd878dab28c77584595215ab48a3588485ff Mon Sep 17 00:00:00 2001 From: skiffer-git <44203734@qq.com> Date: Tue, 14 May 2024 12:15:22 +0800 Subject: [PATCH] Add etcd as a service discovery mechanism --- internal/push/onlinepusher.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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 }