thanks @jw-gadgetworks for pointing this error out!! (TooTallNate#147)

Davidiusdadi · Davidiusdadi · commit d74858c0f77f · 2013-01-10T22:42:10.000+01:00
diff --git a/src/main/java/org/java_websocket/server/WebSocketServer.java b/src/main/java/org/java_websocket/server/WebSocketServer.java
@@ -359,10 +359,14 @@ public void run() {
 						conn = iqueue.remove( 0 );
 						WrappedByteChannel c = ( (WrappedByteChannel) conn.channel );
 						ByteBuffer buf = takeBuffer();
-						if( SocketChannelIOHelper.readMore( buf, conn, c ) )
-							iqueue.add( conn );
-						conn.inQueue.put( buf );
-						queue( conn );
+						try {
+							if( SocketChannelIOHelper.readMore( buf, conn, c ) )
+								iqueue.add( conn );
+							conn.inQueue.put( buf );
+							queue( conn );
+						} finally {
+							pushBuffer( buf );
+						}
 
 					}
 				} catch ( CancelledKeyException e ) {
@@ -381,7 +385,6 @@ public void run() {
 			handleFatal( null, e );
 		}
 	}
-
 	protected void allocateBuffers( WebSocket c ) throws InterruptedException {
 		if( queuesize.get() >= 2 * decoders.size() + 1 ) {
 			return;
