summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java9
1 files changed, 6 insertions, 3 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java b/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java
index ca7fc5abf6..a7c7d87a6e 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java
@@ -88,9 +88,9 @@ public abstract class FlowableBaseQueueEntryList implements QueueEntryList
protected void showUsage(String prefix)
{
- if (_log.isDebugEnabled())
+ if (_log.isTraceEnabled())
{
- _log.debug(prefix + " Queue(" + _queue.getName() + ") usage:" + memoryUsed()
+ _log.trace(prefix + " Queue(" + _queue.getName() + ") usage:" + memoryUsed()
+ "/" + getMemoryUsageMinimum() + "<>" + getMemoryUsageMaximum()
+ "/" + dataSize());
}
@@ -527,7 +527,10 @@ public abstract class FlowableBaseQueueEntryList implements QueueEntryList
//If we are still flowed and are over the minimum value then schedule to run again.
if (_flowed.get() && _atomicQueueInMemory.get() > _memoryUsageMinimum)
{
- _log.info("Rescheduling Purger:" + _queue.getName());
+ if (_log.isInfoEnabled())
+ {
+ _log.info("Rescheduling Purger:" + _queue.getName());
+ }
_purger.execute(messagePurger);
}
}