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:29:50 UTC
[activemq] branch master 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 master
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/master by this push:
new 7ef90e2 Add missing format argument for log message in AbortSlowAckConsumerStrategy#abortAllQualifiedSlowConsumers.
new ef76337 Merge pull request #483 from PascalSchumacher/add_mising_argument_to_log_message
7ef90e2 is described below
commit 7ef90e243fe325488d28f4a08256de0bccba61fc
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.
---
.../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 0623d50..c9b078f 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());