diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java index 8cec751825..551d1c5bae 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java @@ -494,6 +494,10 @@ public class NonBlockingConnection implements NetworkConnection, ByteBufferSende byteBuffersWritten++; _buffers.poll(); } + else + { + break; + } } @@ -524,6 +528,10 @@ public class NonBlockingConnection implements NetworkConnection, ByteBufferSende byteBuffersWritten++; _buffers.poll(); } + else + { + break; + } } } @@ -582,7 +590,7 @@ public class NonBlockingConnection implements NetworkConnection, ByteBufferSende { LOGGER.warn("Send ignored as the connection is already closed"); } - else + else if (msg.remaining() > 0) { _buffers.add(msg); } |