activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r1063214 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
Date Tue, 25 Jan 2011 10:39:11 GMT
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) {



Mime
View raw message