src/org/redkale/net/http/WebSocketEngine.java

@@ -62,6 +62,10 @@ public final class WebSocketEngine {
         if (finest) logger.finest(this.getClass().getSimpleName() + "(" + engineid + ")" + " start keeplive(delay:" + delay + ", interval:" + liveinterval + "s) scheduler executor");
     }
 
+    void destroy(AnyValue conf) {
+        if (scheduler != null) scheduler.shutdownNow();
+    }
+
     void add(WebSocket socket) {
         WebSocketGroup group = containers.get(socket._groupid);
         if (group == null) {
@@ -93,10 +97,6 @@ public final class WebSocketEngine {
         return containers.get(groupid);
     }
 
-    void close() {
-        if (scheduler != null) scheduler.shutdownNow();
-    }
-
     public String getEngineid() {
         return engineid;
     }

src/org/redkale/net/http/WebSocketServlet.java

@@ -89,7 +89,7 @@ public abstract class WebSocketServlet extends HttpServlet implements Resourcabl
     final void postDestroy(HttpContext context, AnyValue conf) {
         this.node.postDestroy(conf);
         super.destroy(context, conf);
-        engine.close();
+        this.engine.destroy(conf);
     }
 
     @Override