From 0c59552dc14c9023d4c0a9d57509cce1d5a6d6da Mon Sep 17 00:00:00 2001 From: feiyu02 <risaku@163.com> Date: 星期二, 31 十二月 2024 10:07:45 +0800 Subject: [PATCH] Merge remote-tracking branch 'supervision/hc-socket-1129' --- src/main/kotlin/cn/flightfeather/supervision/socket/config/SPTextWebSocketHandler.kt | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/kotlin/cn/flightfeather/supervision/socket/config/SPTextWebSocketHandler.kt b/src/main/kotlin/cn/flightfeather/supervision/socket/config/SPTextWebSocketHandler.kt index e66e71e..bf27c37 100644 --- a/src/main/kotlin/cn/flightfeather/supervision/socket/config/SPTextWebSocketHandler.kt +++ b/src/main/kotlin/cn/flightfeather/supervision/socket/config/SPTextWebSocketHandler.kt @@ -1,7 +1,7 @@ package cn.flightfeather.supervision.socket.config import cn.flightfeather.supervision.common.utils.Constant -import cn.flightfeather.supervision.socket.WebSocketMessageDecoder +import cn.flightfeather.supervision.socket.WebSocketMessageParser import cn.flightfeather.supervision.socket.WsSessionManager import cn.flightfeather.supervision.socket.processor.WebSocketReceiver import org.springframework.stereotype.Component @@ -47,7 +47,7 @@ val payload = message.payload val sessionId = session.attributes["session_id"] println("server 鎺ユ敹鍒� $sessionId 鍙戦�佺殑 $payload") - if (WebSocketMessageDecoder.decodeMessage(payload).type == + if (WebSocketMessageParser.decodeMessage(payload).type == Constant.SocketHeartMessageType.HEART_MESSAGE_TYPE.value) { webSocketReceiver.onReceiveHeartMsg(payload, sessionId.toString()) } -- Gitblit v1.9.3