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)
 	}