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

Browse Source
This commit is contained in:
wentch
2015-12-17 11:42:44 +08:00
parent 8795a3553f
commit e459393dd5
1 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/org/redkale/service/WebSocketNodeService.java
View File

@@ -52,14 +52,12 @@ public class WebSocketNodeService extends WebSocketNode implements Service {
} }
@Override @Override
@MultiRun
public void connect(Serializable groupid, InetSocketAddress addr) { public void connect(Serializable groupid, InetSocketAddress addr) {
source.appendSetItem(groupid, addr); source.appendSetItem(groupid, addr);
if (finest) logger.finest(WebSocketNodeService.class.getSimpleName() + ".event: " + groupid + " connect from " + addr); if (finest) logger.finest(WebSocketNodeService.class.getSimpleName() + ".event: " + groupid + " connect from " + addr);
} }
@Override @Override
@MultiRun
public void disconnect(Serializable groupid, InetSocketAddress addr) { public void disconnect(Serializable groupid, InetSocketAddress addr) {
source.removeSetItem(groupid, addr); source.removeSetItem(groupid, addr);
if (finest) logger.finest(WebSocketNodeService.class.getSimpleName() + ".event: " + groupid + " disconnect from " + addr); if (finest) logger.finest(WebSocketNodeService.class.getSimpleName() + ".event: " + groupid + " disconnect from " + addr);