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();
         }
     }