lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2017-05-02 08:10:51 +08:00
parent d800a33ded
commit 33f49c7632
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/org/redkale/net/http/WebSocketEngine.java
View File

@@ -69,7 +69,7 @@ public final class WebSocketEngine {
containers.putIfAbsent(socket._groupid, group); containers.putIfAbsent(socket._groupid, group);
} }
group.add(socket); 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) { void remove(WebSocket socket) {

2
src/org/redkale/net/http/WebSocketNode.java
View File

@@ -111,7 +111,7 @@ public abstract class WebSocketNode {
return map; 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 + ")."); if (finest) logger.finest(localSncpAddress + " receive websocket connect event (" + groupid + " on " + engineid + ").");
Set<String> engineids = localNodes.get(groupid); Set<String> engineids = localNodes.get(groupid);
if (engineids == null) { if (engineids == null) {