diff options
Diffstat (limited to 'java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java b/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java index 8ee2638729..d6d1df573c 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java +++ b/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java @@ -100,7 +100,7 @@ final class IoReceiver extends Thread InputStream in = socket.getInputStream(); int read = 0; int offset = 0; - while (!closed.get() && (read = in.read(buffer, offset, bufferSize-offset)) != -1) + while ((read = in.read(buffer, offset, bufferSize-offset)) != -1) { if (read > 0) { |