diff --git a/netty-websocket-http1/src/main/java/com/jauntsdn/netty/handler/codec/http/websocketx/WebSocketClientProtocolHandler.java b/netty-websocket-http1/src/main/java/com/jauntsdn/netty/handler/codec/http/websocketx/WebSocketClientProtocolHandler.java index ea31759..fdda21c 100644 --- a/netty-websocket-http1/src/main/java/com/jauntsdn/netty/handler/codec/http/websocketx/WebSocketClientProtocolHandler.java +++ b/netty-websocket-http1/src/main/java/com/jauntsdn/netty/handler/codec/http/websocketx/WebSocketClientProtocolHandler.java @@ -93,6 +93,11 @@ public ChannelFuture handshakeCompleted() { return completed; } + @Override + public boolean isSharable() { + return false; + } + @Override public void handlerAdded(ChannelHandlerContext ctx) { handshakeCompleted = ctx.newPromise(); diff --git a/netty-websocket-http1/src/main/java/com/jauntsdn/netty/handler/codec/http/websocketx/WebSocketServerProtocolHandler.java b/netty-websocket-http1/src/main/java/com/jauntsdn/netty/handler/codec/http/websocketx/WebSocketServerProtocolHandler.java index d8ae34a..49d0c76 100644 --- a/netty-websocket-http1/src/main/java/com/jauntsdn/netty/handler/codec/http/websocketx/WebSocketServerProtocolHandler.java +++ b/netty-websocket-http1/src/main/java/com/jauntsdn/netty/handler/codec/http/websocketx/WebSocketServerProtocolHandler.java @@ -87,6 +87,11 @@ public ChannelFuture handshakeCompleted() { return completed; } + @Override + public boolean isSharable() { + return false; + } + @Override public void handlerAdded(ChannelHandlerContext ctx) { handshakeCompleted = ctx.newPromise();