You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ce...@apache.org on 2013/02/13 06:18:21 UTC
svn commit: r1445474 -
/activemq/trunk/activemq-client/src/main/java/org/apache/activemq/usage/Usage.java
Author: ceposta
Date: Wed Feb 13 05:18:21 2013
New Revision: 1445474
URL: http://svn.apache.org/r1445474
Log:
Fix for https://issues.apache.org/jira/browse/AMQ-4309 Add usage limit check when limit for destinations is present
Modified:
activemq/trunk/activemq-client/src/main/java/org/apache/activemq/usage/Usage.java
Modified: activemq/trunk/activemq-client/src/main/java/org/apache/activemq/usage/Usage.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-client/src/main/java/org/apache/activemq/usage/Usage.java?rev=1445474&r1=1445473&r2=1445474&view=diff
==============================================================================
--- activemq/trunk/activemq-client/src/main/java/org/apache/activemq/usage/Usage.java (original)
+++ activemq/trunk/activemq-client/src/main/java/org/apache/activemq/usage/Usage.java Wed Feb 13 05:18:21 2013
@@ -295,6 +295,10 @@ public abstract class Usage<T extends Us
if (started.compareAndSet(false, true)){
if (parent != null) {
parent.addChild(this);
+ if(getLimit() > parent.getLimit()) {
+ LOG.info("Usage({}) limit={} should be smaller than its parent limit={}",
+ new Object[]{getName(), getLimit(), parent.getLimit()});
+ }
}
for (T t:children) {
t.start();