上传网关用户离线通知
This commit is contained in:
parent
9adbc2492d
commit
d241547c51
@ -94,6 +94,16 @@ func (this *AgentMgrComp) DisConnect(a IAgent) {
|
|||||||
}, nil); err != nil {
|
}, nil); err != nil {
|
||||||
log.Errorf("uId:%s Rpc_NoticeUserClose err:%v", a.UserId(), err)
|
log.Errorf("uId:%s Rpc_NoticeUserClose err:%v", a.UserId(), err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if _, err := this.service.AcrossClusterRpcGo(context.Background(), db.CrossTag(), comm.Service_Mainte, string(comm.Rpc_GatewayNoticeUserClose), &pb.NoticeUserCloseReq{
|
||||||
|
Ip: a.IP(),
|
||||||
|
ServiceTag: this.service.GetTag(),
|
||||||
|
GatewayServiceId: this.service.GetId(),
|
||||||
|
UserSessionId: a.SessionId(),
|
||||||
|
UserId: a.UserId(),
|
||||||
|
}, nil); err != nil {
|
||||||
|
log.Errorf("uId:%s Rpc_NoticeUserClose err:%v", a.UserId(), err)
|
||||||
|
}
|
||||||
// }
|
// }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user