You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2022/01/14 20:07:08 UTC
[activemq-artemis] 33/47: fix intermittent failure of org.apache.activemq.artemis.tests.integration.client.ConsumerTest#testSendAMQPReceiveCore
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 <ga...@gmail.com>
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