From 7ef90e243fe325488d28f4a08256de0bccba61fc Mon Sep 17 00:00:00 2001 From: Pascal Schumacher Date: Thu, 27 Feb 2020 22:03:41 +0100 Subject: [PATCH] Add missing format argument for log message in AbortSlowAckConsumerStrategy#abortAllQualifiedSlowConsumers. --- .../broker/region/policy/AbortSlowAckConsumerStrategy.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java index 0623d50442..c9b078f5b0 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java @@ -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());