| | |
| | | import cn.flightfeather.supervision.common.log.WorkStreamLogInfo |
| | | import cn.flightfeather.supervision.common.utils.Constant |
| | | import cn.flightfeather.supervision.socket.WebSocketMessage |
| | | import cn.flightfeather.supervision.socket.WebSocketMessageUtil |
| | | import cn.flightfeather.supervision.socket.WebSocketMessageParser |
| | | import org.springframework.stereotype.Component |
| | | import java.time.LocalDateTime |
| | | |
| | |
| | | * 接收心跳消息处理 |
| | | */ |
| | | fun onReceiveHeartMsg(msg: String, sessionId: String) { |
| | | val content = WebSocketMessageUtil.encodeMessage(WebSocketMessage(Constant.SocketHeartMessageType.HEART_MESSAGE_TYPE.value, |
| | | val content = WebSocketMessageParser.encodeMessage(WebSocketMessage(Constant.SocketHeartMessageType.HEART_MESSAGE_TYPE.value, |
| | | LocalDateTime.now())) |
| | | webSocketSender.sendMsg(content, sessionId) |
| | | } |