diff --git a/src/org/redkale/net/http/WebSocketServlet.java b/src/org/redkale/net/http/WebSocketServlet.java index 5a8f11feb..e235068d0 100644 --- a/src/org/redkale/net/http/WebSocketServlet.java +++ b/src/org/redkale/net/http/WebSocketServlet.java @@ -243,7 +243,7 @@ public abstract class WebSocketServlet extends HttpServlet implements Resourcabl WebSocketServlet.this.node.existsWebSocket(userid).whenComplete((rs, nex) -> { if (rs) { webSocket.onSingleRepeatConnect(); - webSocket.forceCloseWebSocket(userid).whenComplete((fr, fex) -> { + node.forceCloseWebSocket(userid).whenComplete((fr, fex) -> { WebSocketServlet.this.node.localEngine.add(webSocket); WebSocketRunner runner = new WebSocketRunner(context, webSocket, restMessageConsumer, response.removeChannel()); webSocket._runner = runner;