From 7361823ece607c8ceb8baafd7d4fc2521e18b60f Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Sat, 2 Jun 2018 09:17:34 +0800 Subject: [PATCH] --- src/org/redkale/net/http/WebSocketNode.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index eacf16fd1..f4ee6a60b 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -71,7 +71,7 @@ public abstract class WebSocketNode { public final void postDestroy(AnyValue conf) { if (this.localEngine == null) return; //关掉所有本地本地WebSocket - this.localEngine.getLocalWebSockets().forEach(g -> disconnect(g.getUserid())); + this.localEngine.getLocalWebSockets().forEach(g -> disconnect(g.getUserid()).join()); if (sncpNodeAddresses != null && localSncpAddress != null) { sncpNodeAddresses.removeSetItem(SOURCE_SNCP_ADDRS_KEY, localSncpAddress); }