liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

上传用户会话消息谁送接口

Browse Source
This commit is contained in:
liwei1dao 2022-07-04 19:23:35 +08:00
parent 4a367661e7
commit 96daa17ae6
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
comm/usersession.go
View File

@ -149,7 +149,8 @@ func (this *UserSession) Polls() []*pb.UserMessage {
func (this *UserSession) Push() (err error) { func (this *UserSession) Push() (err error) {
reply := &pb.RPCMessageReply{} reply := &pb.RPCMessageReply{}
if _, err = this.service.RpcGo(context.Background(), fmt.Sprintf("%s/%s", Service_Gateway, this.GatewayServiceId), string(Rpc_GatewayAgentSendMsg), &pb.AgentSendMessageReq{ 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 { }, reply); err != nil {
log.Errorf("SendMsgToUsers:%v err:%v", this, err) log.Errorf("SendMsgToUsers:%v err:%v", this, err)
} }