activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject git commit: https://issues.apache.org/jira/browse/AMQ-4621 - return modified trace logging
Date Mon, 16 Sep 2013 13:23:52 GMT
Updated Branches:
  refs/heads/trunk 25af8e62c -> 269d44cfd


https://issues.apache.org/jira/browse/AMQ-4621 - return modified trace logging


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/269d44cf
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/269d44cf
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/269d44cf

Branch: refs/heads/trunk
Commit: 269d44cfdde82ba60f3f3b50b9eca18c29a38e5c
Parents: 25af8e6
Author: Dejan Bosanac <dejan@nighttale.net>
Authored: Mon Sep 16 15:23:37 2013 +0200
Committer: Dejan Bosanac <dejan@nighttale.net>
Committed: Mon Sep 16 15:23:37 2013 +0200

----------------------------------------------------------------------
 .../broker/region/policy/AbortSlowAckConsumerStrategy.java   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/269d44cf/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java
----------------------------------------------------------------------
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 dedb580..b9dd9f8 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
@@ -149,10 +149,10 @@ public class AbortSlowAckConsumerStrategy extends AbortSlowConsumerStrategy
{
             if (getMaxSlowDuration() > 0 && (entry.getValue().markCount * getCheckPeriod()
>= getMaxSlowDuration()) ||
                 getMaxSlowCount() > 0 && entry.getValue().slowCount >= getMaxSlowCount())
{
 
-                LOG.trace("Transferring consumer {} to the abort list: " +
-                              "slow duration = " + entry.getValue().markCount * getCheckPeriod()
+ ", " +
-                              "slow count = " + entry.getValue().slowCount,
-                              entry.getKey().getConsumerInfo().getConsumerId());
+                LOG.trace("Transferring consumer{} to the abort list: {} slow duration =
{}, slow count = {}",
+                        new Object[]{ entry.getKey().getConsumerInfo().getConsumerId(),
+                        entry.getValue().markCount * getCheckPeriod(),
+                        entry.getValue().getSlowCount() });
 
                 toAbort.put(entry.getKey(), entry.getValue());
                 slowConsumers.remove(entry.getKey());


Mime
View raw message