diff options
author | Robert Godfrey <rgodfrey@apache.org> | 2013-12-10 14:44:23 +0000 |
---|---|---|
committer | Robert Godfrey <rgodfrey@apache.org> | 2013-12-10 14:44:23 +0000 |
commit | 75b1fbd3a04b61bd2f42f37058f80d177bc718ba (patch) | |
tree | 3f9f479298adf51cbd478343e52012343c051c07 | |
parent | 35078b9841e51abb442493611a237acb60086743 (diff) | |
download | qpid-python-75b1fbd3a04b61bd2f42f37058f80d177bc718ba.tar.gz |
Merged r1549669 to 0.26 branch
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.26@1549851 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java index c155a52cd9..119dd6bf3a 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java @@ -331,15 +331,12 @@ public class ConnectionHandler public void getBytes(final BytesProcessor processor, final boolean wait) { - if(!_conn.closedForOutput()) - { - processor.processBytes(_buffer); - } + processor.processBytes(_buffer); } public boolean closed() { - return !_conn.closedForOutput() && !_buffer.hasRemaining(); + return !_buffer.hasRemaining(); } } |