diff --git a/src/main/java/org/java_websocket/server/WebSocketServer.java b/src/main/java/org/java_websocket/server/WebSocketServer.java index e02a1f787..dac79ac9d 100644 --- a/src/main/java/org/java_websocket/server/WebSocketServer.java +++ b/src/main/java/org/java_websocket/server/WebSocketServer.java @@ -328,6 +328,12 @@ public void run() { onStart(); } catch ( IOException ex ) { handleFatal( null, ex ); + //Shutting down WebSocketWorkers, see #222 + if( decoders != null ) { + for( WebSocketWorker w : decoders ) { + w.interrupt(); + } + } return; } try {