This is an automated email from the ASF dual-hosted git repository. clebertsuconic pushed a commit to branch 2.19.x in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit 4f9b434dbb4c6519bbc8a51c4b6d7bc6e25173de Author: gtully <[email protected]> AuthorDate: Wed Dec 8 15:04:39 2021 +0000 fix intermittent failure of org.apache.activemq.artemis.tests.integration.client.ConsumerTest#testSendAMQPReceiveCore (cherry picked from commit dcb6292def0b3a63770fdba2df16d58db52aec51) --- .../org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java index ca73b64..85638ec 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java @@ -966,6 +966,9 @@ public abstract class AMQPMessage extends RefCountMessage implements org.apache. scanMessageData(); messageDataScanned = MessageDataScanningStatus.SCANNED.code; modified = false; + // reinitialise memory estimate as message will already be on a queue + // and lazy decode will want to update + getMemoryEstimate(); } @Override
