From 267733cff99a6ac03ff554337f862c8f4dd21ec5 Mon Sep 17 00:00:00 2001 From: skiffer-git <44203734@qq.com> Date: Tue, 14 May 2024 12:26:50 +0800 Subject: [PATCH] Add etcd as a service discovery mechanism --- internal/push/onlinepusher.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/push/onlinepusher.go b/internal/push/onlinepusher.go index 9a2c52f01..a61399fb6 100644 --- a/internal/push/onlinepusher.go +++ b/internal/push/onlinepusher.go @@ -87,6 +87,7 @@ 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)