diff options
| author | Gordon Sim <gsim@apache.org> | 2014-01-08 18:42:12 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2014-01-08 18:42:12 +0000 |
| commit | 8f8b2b17e34bf7a71159208ce838e76f0bef4247 (patch) | |
| tree | cac9208a8c07d89ee2d0b329496aaba4b8251a65 /java | |
| parent | bd1a076d29554980db3029217facba858150380c (diff) | |
| download | qpid-python-8f8b2b17e34bf7a71159208ce838e76f0bef4247.tar.gz | |
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/qpid@1556603 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java b/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java index 83cb36246a..bc16ba14e0 100644 --- a/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/framing/FrameHandler.java +++ b/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; } |