diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java index c358d3bd3b..0c65b583ff 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java @@ -159,7 +159,7 @@ final class IoSender extends Thread implements Sender<ByteBuffer> public void close() { - if (closed.getAndSet(true)) + if (!closed.getAndSet(true)) { synchronized (notEmpty) { @@ -244,9 +244,8 @@ final class IoSender extends Thread implements Sender<ByteBuffer> } catch (IOException e) { - log.error(e, "error in read thread"); + log.error(e, "error in write thread"); exception = e; - closed.set(true); break; } tail.getAndAdd(length); |