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

Browse Source
This commit is contained in:
Redkale
2016-08-24 13:55:44 +08:00
parent 5a1586bc6a
commit 8e639e32a3
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -68,9 +68,10 @@ public abstract class WebSocketServlet extends HttpServlet {
public final void preInit(HttpContext context, AnyValue conf) { public final void preInit(HttpContext context, AnyValue conf) {
InetSocketAddress addr = context.getServerAddress(); InetSocketAddress addr = context.getServerAddress();
this.engine = new WebSocketEngine(addr.getHostString() + ":" + addr.getPort() + "-[" + name() + "]", this.node, logger); this.engine = new WebSocketEngine(addr.getHostString() + ":" + addr.getPort() + "-[" + name() + "]", this.node, logger);
if (this.node == null) this.node = createWebSocketNode();
if (this.node == null) { if (this.node == null) {
this.node = new WebSocketNodeService(); this.node = new WebSocketNodeService();
if (logger.isLoggable(Level.INFO)) logger.info("not found WebSocketNode, create a default value for " + getClass().getName()); if (logger.isLoggable(Level.WARNING)) logger.warning("Not found WebSocketNode, create a default value for " + getClass().getName());
} }
this.node.putWebSocketEngine(engine); this.node.putWebSocketEngine(engine);
this.node.init(conf); this.node.init(conf);
@@ -149,5 +150,9 @@ public abstract class WebSocketServlet extends HttpServlet {
}); });
} }
protected WebSocketNode createWebSocketNode() {
return null;
}
protected abstract WebSocket createWebSocket(); protected abstract WebSocket createWebSocket();
} }