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:19:32 +08:00
parent abcfb8f10c
commit a1b39ba99b
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/net/http/WebSocketNode.java
View File

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