fixed problem with thread interrupt (TooTallNate#119)

Davidiusdadi · Davidiusdadi · commit c5e3c818aa7e · 2012-09-20T01:33:11.000+02:00
diff --git a/src/org/java_websocket/WebSocketImpl.java b/src/org/java_websocket/WebSocketImpl.java
@@ -542,11 +542,15 @@ public void startHandshake( ClientHandshakeBuilder handshakedata ) throws Invali
 	private void write( ByteBuffer buf ) {
 		if( DEBUG )
 			System.out.println( "write(" + buf.remaining() + "): {" + ( buf.remaining() > 1000 ? "too big to display" : new String( buf.array() ) ) + "}" );
-		try {
+		
+		outQueue.add( buf );
+		/*try {
 			outQueue.put( buf );
 		} catch ( InterruptedException e ) {
+			write( buf );
+			Thread.currentThread().interrupt(); // keep the interrupted status
 			e.printStackTrace();
-		}
+		}*/
 		wsl.onWriteDemand( this );
 	}
 
