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 | 8a52bc7caed02465fd9dad7fd4924929cad22598 (patch) | |
| tree | 503369e0002b53031f133cb230922b4ed5703590 | |
| parent | a349235a740342e614b0c78befc99241c694a7e6 (diff) | |
| download | qpid-python-8a52bc7caed02465fd9dad7fd4924929cad22598.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@1556603 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/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/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; } |