Author: gsim
Date: Wed Jan 8 18:42:12 2014
New Revision: 1556603
URL: http://svn.apache.org/r1556603
Log:
QPID-5456: Use the local max-frame-size when enforcing limit on what is
received, not that of the peer
Modified:
qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java
Modified:
qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.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/FrameHandler.java?rev=1556603&r1=1556602&r2=1556603&view=diff
==============================================================================
---
qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java
(original)
+++
qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java
Wed Jan 8 18:42:12 2014
@@ -127,9 +127,9 @@ public class FrameHandler implements Pro
break;
}
- else if(size > _connection.getMaxFrameSize())
+ else if(size >
_connection.getDesiredMaxFrameSize().intValue())
{
- frameParsingError = createFramingError("specified
frame size %d larger than maximum frame header size %d", size,
_connection.getMaxFrameSize());
+ frameParsingError = createFramingError("specified
frame size %d larger than maximum frame header size %d", size,
_connection.getDesiredMaxFrameSize().intValue());
state = State.ERROR;
break;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
