diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 541e15073..9889004ac 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -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 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 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;