Skip to content

Commit 9c66968

Browse files
nozdrya.d.anozdrya.d.a
authored andcommitted
ARTEMIS-5834 Additional debug log in ScaleDownHandler
Adds additional debug log about scaled-down messages on address
1 parent bfab102 commit 9c66968

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ScaleDownHandler.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -139,12 +139,14 @@ public long scaleDownMessages(ClientSessionFactory sessionFactory,
139139
}
140140

141141
String sfPrefix = ((PostOfficeImpl) postOffice).getServer().getInternalNamingPrefix() + "sf.";
142+
long messageCountItem = 0;
142143
if (address.toString().startsWith(sfPrefix)) {
143-
messageCount += scaleDownSNF(address, queues, producer);
144+
messageCountItem += scaleDownSNF(address, queues, producer);
144145
} else {
145-
messageCount += scaleDownRegularMessages(address, queues, session, producer);
146+
messageCountItem += scaleDownRegularMessages(address, queues, session, producer);
146147
}
147-
148+
logger.debug("Scaled down {} messages on address {}", messageCountItem, address);
149+
messageCount += messageCountItem;
148150
}
149151
}
150152

0 commit comments

Comments
 (0)