From fb52815020ef211b4639f4939e82aacecd9cbd41 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Wed, 28 Jun 2023 16:08:54 +0800 Subject: [PATCH] zk conn --- internal/push/push_to_client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/push/push_to_client.go b/internal/push/push_to_client.go index 4383c336a..7eead73ee 100644 --- a/internal/push/push_to_client.go +++ b/internal/push/push_to_client.go @@ -247,7 +247,7 @@ func (p *Pusher) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, for _, v := range conns { msgClient := msggateway.NewMsgGatewayClient(v) reply, err := msgClient.SuperGroupOnlineBatchPushOneMsg(ctx, &msggateway.OnlineBatchPushOneMsgReq{MsgData: msg, PushToUserIDs: pushToUserIDs}) - v.Close() + p.discov.CloseConn(v) if err != nil { continue }