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/10 15:44:24 UTC
svn commit: r1549851 - in /qpid/branches/0.26/qpid/java: ./ amqp-1-0-common/
amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java
Author: rgodfrey
Date: Tue Dec 10 14:44:23 2013
New Revision: 1549851
URL: http://svn.apache.org/r1549851
Log:
Merged r1549669 to 0.26 branch
Modified:
qpid/branches/0.26/qpid/java/ (props changed)
qpid/branches/0.26/qpid/java/amqp-1-0-common/ (props changed)
qpid/branches/0.26/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java
Propchange: qpid/branches/0.26/qpid/java/
------------------------------------------------------------------------------
Merged /qpid/trunk/qpid/java:r1549669
Propchange: qpid/branches/0.26/qpid/java/amqp-1-0-common/
------------------------------------------------------------------------------
Merged /qpid/trunk/qpid/java/amqp-1-0-common:r1549669
Modified: qpid/branches/0.26/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/branches/0.26/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java?rev=1549851&r1=1549850&r2=1549851&view=diff
==============================================================================
--- qpid/branches/0.26/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java (original)
+++ qpid/branches/0.26/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/ConnectionHandler.java Tue Dec 10 14:44:23 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