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();