You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2020/02/28 06:30:37 UTC
[activemq] branch activemq-5.15.x updated: Add missing format
argument for log message in
AbortSlowAckConsumerStrategy#abortAllQualifiedSlowConsumers.
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 <pa...@gmx.net>
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());