This is an automated email from the ASF dual-hosted git repository.

tabish pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new e7a437d  ARTEMIS-2706 Discounting Transfer payload size
     new 8ac9649  This closes #3082
e7a437d is described below

commit e7a437d9996464d29e63b82336d2d0eaf69e338c
Author: Clebert Suconic <[email protected]>
AuthorDate: Tue Apr 14 16:56:52 2020 -0400

    ARTEMIS-2706 Discounting Transfer payload size
---
 .../artemis/protocol/amqp/proton/ProtonServerSenderContext.java        | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerSenderContext.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerSenderContext.java
index 4810519..ca3d418 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerSenderContext.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerSenderContext.java
@@ -838,7 +838,8 @@ public class ProtonServerSenderContext extends 
ProtonInitializable implements Pr
       }
       void deliver() {
 
-         int frameSize = 
protonSession.session.getConnection().getTransport().getOutboundFrameSizeLimit();
+         // This is discounting some bytes due to Transfer payload
+         int frameSize = 
protonSession.session.getConnection().getTransport().getOutboundFrameSizeLimit()
 - 50 - (delivery.getTag() != null ? delivery.getTag().length : 0);
 
          // Let the Message decide how to present the message bytes
          LargeBodyReader context = message.getLargeBodyReader();

Reply via email to