From 9c66968c9d2667172d229da13cb7549de85ae91a Mon Sep 17 00:00:00 2001 From: "nozdrya.d.a" Date: Tue, 23 Dec 2025 13:31:55 +0300 Subject: [PATCH] ARTEMIS-5834 Additional debug log in ScaleDownHandler Adds additional debug log about scaled-down messages on address --- .../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 c45a8ae9492..d921fbcfff0 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 long scaleDownMessages(ClientSessionFactory sessionFactory, } 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; } }