Author: dejanb Date: Tue Jan 25 10:39:11 2011 New Revision: 1063214 URL: http://svn.apache.org/viewvc?rev=1063214&view=rev Log: https://issues.apache.org/jira/browse/AMQ-3143 - additional commit for storeUsage limit change Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java?rev=1063214&r1=1063213&r2=1063214&view=diff ============================================================================== --- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (original) +++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java Tue Jan 25 10:39:11 2011 @@ -189,7 +189,7 @@ public class Queue extends BaseDestinati } } 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 BaseDestinati if (memoryUsage != null) { memoryUsage.start(); } + if (systemUsage.getStoreUsage() != null) { + systemUsage.getStoreUsage().start(); + } systemUsage.getMemoryUsage().addUsageListener(this); messages.start(); if (getExpireMessagesPeriod() > 0) {