Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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

This commit is contained in:
Dejan Bosanac 2013-09-16 15:23:37 +02:00
parent 25af8e62cc
commit 269d44cfdd
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java
View File

@ -149,10 +149,10 @@ public class AbortSlowAckConsumerStrategy extends AbortSlowConsumerStrategy {
if (getMaxSlowDuration() > 0 && (entry.getValue().markCount * getCheckPeriod() >= getMaxSlowDuration()) || if (getMaxSlowDuration() > 0 && (entry.getValue().markCount * getCheckPeriod() >= getMaxSlowDuration()) ||
getMaxSlowCount() > 0 && entry.getValue().slowCount >= getMaxSlowCount()) { getMaxSlowCount() > 0 && entry.getValue().slowCount >= getMaxSlowCount()) {
LOG.trace("Transferring consumer {} to the abort list: " + LOG.trace("Transferring consumer{} to the abort list: {} slow duration = {}, slow count = {}",
"slow duration = " + entry.getValue().markCount * getCheckPeriod() + ", " + new Object[]{ entry.getKey().getConsumerInfo().getConsumerId(),
"slow count = " + entry.getValue().slowCount, entry.getValue().markCount * getCheckPeriod(),
entry.getKey().getConsumerInfo().getConsumerId()); entry.getValue().getSlowCount() });
toAbort.put(entry.getKey(), entry.getValue()); toAbort.put(entry.getKey(), entry.getValue());
slowConsumers.remove(entry.getKey()); slowConsumers.remove(entry.getKey());