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
 		}