This is an automated email from the ASF dual-hosted git repository.
jbertram pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/artemis.git
The following commit(s) were added to refs/heads/main by this push:
new 21c1c6ddfa ARTEMIS-5834 Additional debug log in ScaleDownHandler Adds
additional debug log about scaled-down messages on address
21c1c6ddfa is described below
commit 21c1c6ddfa789092b1cd86272c09d46bc086bcce
Author: nozdrya.d.a <[email protected]>
AuthorDate: Tue Dec 23 13:31:55 2025 +0300
ARTEMIS-5834 Additional debug log in ScaleDownHandler
Adds additional debug log about scaled-down messages on address
---
.../activemq/artemis/core/server/impl/ScaleDownHandler.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ScaleDownHandler.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ScaleDownHandler.java
index c45a8ae949..d921fbcfff 100644
---
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ScaleDownHandler.java
+++
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ScaleDownHandler.java
@@ -139,12 +139,14 @@ public class ScaleDownHandler {
}
String sfPrefix = ((PostOfficeImpl)
postOffice).getServer().getInternalNamingPrefix() + "sf.";
+ long messageCountItem = 0;
if (address.toString().startsWith(sfPrefix)) {
- messageCount += scaleDownSNF(address, queues, producer);
+ messageCountItem += scaleDownSNF(address, queues, producer);
} else {
- messageCount += scaleDownRegularMessages(address, queues,
session, producer);
+ messageCountItem += scaleDownRegularMessages(address, queues,
session, producer);
}
-
+ logger.debug("Scaled down {} messages on address {}",
messageCountItem, address);
+ messageCount += messageCountItem;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
