lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2017-05-02 08:08:25 +08:00
parent f9f2e080da
commit f587e13bdc
3 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/org/redkale/net/http/WebSocketNode.java
View File

@@ -49,7 +49,7 @@ public abstract class WebSocketNode {
} }
public void destroy(AnyValue conf) { public final void postDestroy(AnyValue conf) {
HashMap<Serializable, Set<String>> nodes = new HashMap<>(localNodes); HashMap<Serializable, Set<String>> nodes = new HashMap<>(localNodes);
nodes.forEach((k, v) -> { nodes.forEach((k, v) -> {
new HashSet<>(v).forEach(e -> { new HashSet<>(v).forEach(e -> {

2
src/org/redkale/net/http/WebSocketServlet.java
View File

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

1
src/org/redkale/service/WebSocketNodeService.java
View File

@@ -30,7 +30,6 @@ public class WebSocketNodeService extends WebSocketNode implements Service {
@Override @Override
public void destroy(AnyValue conf) { public void destroy(AnyValue conf) {
super.destroy(conf);
} }
@Override @Override