From cb9f176752c48db2ce32014fc71f2cfcfc729666 Mon Sep 17 00:00:00 2001 From: Bosanac Dejan Date: Tue, 25 Jan 2011 10:39:11 +0000 Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-3143 - additional commit for storeUsage limit change git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1063214 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/activemq/broker/region/Queue.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java index 6f3d877c02..9e5f34b791 100755 --- a/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java @@ -189,7 +189,7 @@ public class Queue extends BaseDestination implements Task, UsageListener { } } catch (InterruptedException e) { if (LOG.isDebugEnabled()) { - LOG.debug(getName() + "P roducer Flow Control Timeout Task is stopping"); + LOG.debug(getName() + "Producer Flow Control Timeout Task is stopping"); } } } @@ -834,6 +834,9 @@ public class Queue extends BaseDestination implements Task, UsageListener { if (memoryUsage != null) { memoryUsage.start(); } + if (systemUsage.getStoreUsage() != null) { + systemUsage.getStoreUsage().start(); + } systemUsage.getMemoryUsage().addUsageListener(this); messages.start(); if (getExpireMessagesPeriod() > 0) {