From f539633497807ea47b864bdf1ec6d9858c0cd189 Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Mon, 28 May 2018 10:01:17 +0800 Subject: [PATCH] --- src/org/redkale/net/http/WebSocketServlet.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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;