diff --git a/das/src/main/java/com/das/modules/node/handler/NodeMessageHandler.java b/das/src/main/java/com/das/modules/node/handler/NodeMessageHandler.java index 1bbcfa55..3bb3d4b4 100644 --- a/das/src/main/java/com/das/modules/node/handler/NodeMessageHandler.java +++ b/das/src/main/java/com/das/modules/node/handler/NodeMessageHandler.java @@ -133,7 +133,7 @@ public class NodeMessageHandler extends TextWebSocketHandler { * 发送ping消息 * @param session */ - private void SendPingMessage(WebSocketSession session){ + private void SendPingMessage(ConcurrentWebSocketSessionDecorator session){ try { session.sendMessage(new PingMessage()); }