This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch activemq-5.15.x
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/activemq-5.15.x by this push:
new c99660d Add missing format argument for log message in
AbortSlowAckConsumerStrategy#abortAllQualifiedSlowConsumers.
c99660d is described below
commit c99660df97d040a6b89d2e304406f9b49310e820
Author: Pascal Schumacher <[email protected]>
AuthorDate: Thu Feb 27 22:03:41 2020 +0100
Add missing format argument for log message in
AbortSlowAckConsumerStrategy#abortAllQualifiedSlowConsumers.
(cherry picked from commit 7ef90e243fe325488d28f4a08256de0bccba61fc)
---
.../activemq/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 06be1f9..68e0148 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
@@ -147,9 +147,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());