From 8a52bc7caed02465fd9dad7fd4924929cad22598 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Wed, 8 Jan 2014 18:42:12 +0000 Subject: QPID-5456: Use the local max-frame-size when enforcing limit on what is received, not that of the peer git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1556603 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java index 83cb36246a..bc16ba14e0 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java @@ -127,9 +127,9 @@ public class FrameHandler implements ProtocolHandler 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; } -- cgit v1.2.1