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 2025/07/09 18:33:32 UTC
(activemq-artemis) branch main updated: ARTEMIS-5564 Tweak on AckManager debug logging
This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new eddff30ec0 ARTEMIS-5564 Tweak on AckManager debug logging
eddff30ec0 is described below
commit eddff30ec03b53b12848a1e2afde41f42d83e824
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Wed Jul 9 14:31:08 2025 -0400
ARTEMIS-5564 Tweak on AckManager debug logging
---
.../activemq/artemis/protocol/amqp/connect/mirror/AckManager.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AckManager.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AckManager.java
index bf399514e2..d387f86ac5 100644
--- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AckManager.java
+++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AckManager.java
@@ -281,6 +281,10 @@ public class AckManager implements ActiveMQComponent {
if (page == null) {
continue;
}
+
+ if (logger.isDebugEnabled()) {
+ logger.debug("scanning for acks on page {}/{} on address {}", page.getPageId(), store.getCurrentWritingPage(), address);
+ }
try {
retryPage(snapshotCount, acksToRetry, address, page);
} finally {
@@ -386,7 +390,6 @@ public class AckManager implements ActiveMQComponent {
Page page) throws Exception {
AckRetry key = new AckRetry();
- logger.debug("scanning for acks on page {} on address {}", page.getPageId(), address);
TransactionImpl transaction = new TransactionImpl(server.getStorageManager()).setAsync(true);
// scan each page for acks
page.getMessages().forEach(pagedMessage -> {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@activemq.apache.org
For additional commands, e-mail: commits-help@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact