diff --git a/src/org/redkale/net/http/WebSocketEngine.java b/src/org/redkale/net/http/WebSocketEngine.java index a68990a5e..77f902fc4 100644 --- a/src/org/redkale/net/http/WebSocketEngine.java +++ b/src/org/redkale/net/http/WebSocketEngine.java @@ -69,7 +69,7 @@ public final class WebSocketEngine { containers.putIfAbsent(socket._groupid, group); } group.add(socket); - if (node != null) node.connect(socket._groupid, engineid, socket.toString()); + if (node != null) node.connect(socket._groupid, engineid); } void remove(WebSocket socket) { diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 48594fdde..93bd0c300 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -111,7 +111,7 @@ public abstract class WebSocketNode { return map; } - public final void connect(Serializable groupid, String engineid, String wsinfo) { + public final void connect(Serializable groupid, String engineid) { if (finest) logger.finest(localSncpAddress + " receive websocket connect event (" + groupid + " on " + engineid + ")."); Set engineids = localNodes.get(groupid); if (engineids == null) {