QPID-5389 : [JMS AMQP 1.0] ConnectionHandler may stop writting pending frames if close is called right after the connection is started (patch from Xin Chen)

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1549669 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 2 insertions, 5 deletions

diff --git a/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java b/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java
index c155a52cd9..119dd6bf3a 100644
--- a/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java
+++ b/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();
         }
     }