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

Merge branch 'bs_2.0.6.28' of http://git.legu.cc/liwei_3d/go_dreamfactory into bs_2.0.6.28

Browse Source
This commit is contained in:
meixiongfeng 2023-07-14 19:03:04 +08:00
commit 8f5141b5e9
1 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
comm/usersession.go
View File

@ -145,7 +145,7 @@ 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 len(this.msgqueue) > 0 { if this.ServiceTag != "" && this.SessionId != "" && len(this.msgqueue) > 0 {
if _, err = this.service.AcrossClusterRpcGo(context.Background(), this.ServiceTag, fmt.Sprintf("%s/%s", Service_Gateway, this.GatewayServiceId), string(Rpc_GatewayAgentSendMsg), &pb.AgentSendMessageReq{ if _, err = this.service.AcrossClusterRpcGo(context.Background(), this.ServiceTag, fmt.Sprintf("%s/%s", Service_Gateway, this.GatewayServiceId), string(Rpc_GatewayAgentSendMsg), &pb.AgentSendMessageReq{
UserSessionId: this.SessionId, UserSessionId: this.SessionId,
Reply: this.msgqueue, Reply: this.msgqueue,