From 96daa17ae6f0d1759fb33afbee7e31fb9926954d Mon Sep 17 00:00:00 2001 From: liwei1dao Date: Mon, 4 Jul 2022 19:23:35 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E7=94=A8=E6=88=B7=E4=BC=9A?= =?UTF-8?q?=E8=AF=9D=E6=B6=88=E6=81=AF=E8=B0=81=E9=80=81=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- comm/usersession.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/comm/usersession.go b/comm/usersession.go index 47afe21bc..75087048b 100644 --- a/comm/usersession.go +++ b/comm/usersession.go @@ -149,7 +149,8 @@ func (this *UserSession) Polls() []*pb.UserMessage { func (this *UserSession) Push() (err error) { reply := &pb.RPCMessageReply{} if _, err = this.service.RpcGo(context.Background(), fmt.Sprintf("%s/%s", Service_Gateway, this.GatewayServiceId), string(Rpc_GatewayAgentSendMsg), &pb.AgentSendMessageReq{ - Reply: this.msgqueue, + UserSessionId: this.SessionId, + Reply: this.msgqueue, }, reply); err != nil { log.Errorf("SendMsgToUsers:%v err:%v", this, err) }