You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2013/12/09 21:34:36 UTC
svn commit: r1549669 -
/qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java
Author: rgodfrey
Date: Mon Dec 9 20:34:36 2013
New Revision: 1549669
URL: http://svn.apache.org/r1549669
Log:
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)
Modified:
qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java
Modified: qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java?rev=1549669&r1=1549668&r2=1549669&view=diff
==============================================================================
--- qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java (original)
+++ qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java Mon Dec 9 20:34:36 2013
@@ -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();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org