diff --git a/src/main/java/org/java_websocket/SSLSocketChannel2.java b/src/main/java/org/java_websocket/SSLSocketChannel2.java index 110cf3805..f5fddfb6a 100644 --- a/src/main/java/org/java_websocket/SSLSocketChannel2.java +++ b/src/main/java/org/java_websocket/SSLSocketChannel2.java @@ -302,7 +302,6 @@ public void close() throws IOException { if( socketChannel.isOpen() ) socketChannel.write( wrap( emptybuffer ) );// FIXME what if not all bytes can be written socketChannel.close(); - exec.shutdownNow(); } private boolean isHandShakeComplete() { diff --git a/src/main/java/org/java_websocket/server/DefaultSSLWebSocketServerFactory.java b/src/main/java/org/java_websocket/server/DefaultSSLWebSocketServerFactory.java index b871260f8..64cdc7bc5 100644 --- a/src/main/java/org/java_websocket/server/DefaultSSLWebSocketServerFactory.java +++ b/src/main/java/org/java_websocket/server/DefaultSSLWebSocketServerFactory.java @@ -48,4 +48,11 @@ public WebSocketImpl createWebSocket( WebSocketAdapter a, Draft d, Socket c ) { public WebSocketImpl createWebSocket( WebSocketAdapter a, List d, Socket s ) { return new WebSocketImpl( a, d ); } + + /** + * shutdown executor service + */ + public void shutdown() { + exec.shutdownNow(); + } } \ No newline at end of file