Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-26 20:15:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add missing format argument for log message in AbortSlowAckConsumerStrategy#abortAllQualifiedSlowConsumers.

Browse Source
This commit is contained in:
Pascal Schumacher 2020-02-27 22:03:41 +01:00
parent 6e650841fd
commit 7ef90e243f
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java
View File

@ -164,9 +164,10 @@ public class AbortSlowAckConsumerStrategy extends AbortSlowConsumerStrategy {
getMaxSlowCount() > 0 && entry.getValue().slowCount >= getMaxSlowCount()) {
LOG.trace("Transferring consumer {} to the abort list: {} slow duration = {}, slow count = {}",
new Object[]{ entry.getKey().getConsumerInfo().getConsumerId(),
entry.getKey().getConsumerInfo().getConsumerId(),
toAbort,
entry.getValue().markCount * getCheckPeriod(),
entry.getValue().getSlowCount() });
entry.getValue().getSlowCount());
toAbort.put(entry.getKey(), entry.getValue());
slowConsumers.remove(entry.getKey());