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:12:19 +08:00
parent 33f49c7632
commit abcfb8f10c
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
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) { 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) {
@@ -122,7 +122,7 @@ public abstract class WebSocketNode {
engineids.add(engineid); engineids.add(engineid);
} }
public final void disconnect(Serializable groupid, String engineid) { final void disconnect(Serializable groupid, String engineid) {
if (finest) logger.finest(localSncpAddress + " receive websocket disconnect event (" + groupid + " on " + engineid + ")."); if (finest) logger.finest(localSncpAddress + " receive websocket disconnect event (" + groupid + " on " + engineid + ").");
Set<String> engineids = localNodes.get(groupid); Set<String> engineids = localNodes.get(groupid);
if (engineids == null || engineids.isEmpty()) return; if (engineids == null || engineids.isEmpty()) return;
@@ -137,7 +137,7 @@ public abstract class WebSocketNode {
engines.put(engine.getEngineid(), engine); engines.put(engine.getEngineid(), engine);
} }
public final int sendMessage(Serializable groupid, boolean recent, Object message, boolean last) { public int sendMessage(Serializable groupid, boolean recent, Object message, boolean last) {
final Set<String> engineids = localNodes.get(groupid); final Set<String> engineids = localNodes.get(groupid);
if (finest) logger.finest("websocket want send message {groupid:" + groupid + ", content:'" + message + "'} from locale node to " + engineids); if (finest) logger.finest("websocket want send message {groupid:" + groupid + ", content:'" + message + "'} from locale node to " + engineids);
int rscode = RETCODE_GROUP_EMPTY; int rscode = RETCODE_GROUP_EMPTY;