websocket并发发送消息

2024-10-22 12:46:25 +08:00 · 2024-10-22 12:46:25 +08:00 · b7b11e4a26
commit b7b11e4a26
parent 5af50a92df
1 changed files with 1 additions and 1 deletions
--- 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());
        }