心跳提示信息
This commit is contained in:
@@ -31,10 +31,10 @@ func (s *ReqHeartBeat) Handle(request ziface.IRequest) {
|
||||
reqId, ok := body.Data["reqId"]
|
||||
if !ok {
|
||||
zlog.Ins().ErrorF("missing parameter of message body")
|
||||
request.GetConnection().SendMsg(ReqHeartBeatMsgType, core.ResultError(ReqHeartBeatName, "missing parameter of message body", ""))
|
||||
request.GetConnection().SendMsg(ReqHeartBeatMsgType, core.ResultError(ReqHeartBeatName, "missing reqId", ""))
|
||||
return
|
||||
}
|
||||
|
||||
//ack
|
||||
request.GetConnection().SendMsg(ReqHeartBeatMsgType, core.ResultSuccess(ReqHeartBeatName, "ok", reqId))
|
||||
request.GetConnection().SendMsg(ReqHeartBeatMsgType, core.ResultSuccess(ReqHeartBeatName, "", reqId))
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user