Author: rgodfrey
Date: Thu Oct 4 21:00:29 2012
New Revision: 1394265
URL: http://svn.apache.org/viewvc?rev=1394265&view=rev
Log:
PROTON-59 : Repect max frame size provided by peer
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java?rev=1394265&r1=1394264&r2=1394265&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
Thu Oct 4 21:00:29 2012
@@ -891,6 +891,11 @@ public class TransportImpl extends Endpo
{
_open = open;
}
+
+ if(open.getMaxFrameSize().longValue() > 0 &&
open.getMaxFrameSize().longValue() < (long) _maxFrameSize)
+ {
+ _maxFrameSize = (int) open.getMaxFrameSize().longValue();
+ }
}
public void handleBegin(Begin begin, Binary payload, Integer channel)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
