diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 74d1ac8cd..4b178ff55 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -354,7 +354,7 @@ public abstract class WebSocketNode { if (this.localEngine != null && this.sncpNodeAddresses == null) { //本地模式且没有分布式 return this.localEngine.sendMessage(message, last, userids); } - final Object remoteMessage = formatRemoteMessage(message0); + final Object remoteMessage = formatRemoteMessage(message); CompletableFuture future = null; for (Serializable userid : userids) { future = future == null ? sendOneMessage(remoteMessage, last, userid)