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-16 16:34:05 +08:00
parent cc69a32e66
commit c2a1ad0100
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -41,11 +41,11 @@ public class WebSocketNodeService extends WebSocketNode implements Service {
if (engine != null) { //在本地 if (engine != null) { //在本地
final WebSocketGroup group = engine.getWebSocketGroup(groupid); final WebSocketGroup group = engine.getWebSocketGroup(groupid);
if (group == null || group.isEmpty()) { if (group == null || group.isEmpty()) {
if (finest) logger.finest("receive websocket message {engineid:'" + engineid + "', groupid:" + groupid + ", content:'" + message + "'} but result is " + RETCODE_GROUP_EMPTY); if (finest) logger.finest("receive websocket message {engineid:'" + engineid + "', groupid:" + groupid + ", content:'" + message + "'} from " + addr + " but send result is " + RETCODE_GROUP_EMPTY);
return RETCODE_GROUP_EMPTY; return RETCODE_GROUP_EMPTY;
} }
code = group.send(recent, message, last); code = group.send(recent, message, last);
if (finest) logger.finest("websocket node send message (" + message + ") result is " + code); if (finest) logger.finest("websocket node send message (" + message + ") from " + addr + " result is " + code);
} }
} }
return code; return code;