You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2011/06/27 12:56:57 UTC

svn commit: r1140098 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx: SubscriptionView.java SubscriptionViewMBean.java

Author: dejanb
Date: Mon Jun 27 10:56:56 2011
New Revision: 1140098

URL: http://svn.apache.org/viewvc?rev=1140098&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3378 - isSlowConsumer for SubscriptionView

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java?rev=1140098&r1=1140097&r2=1140098&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java Mon Jun 27 10:56:56 2011
@@ -305,4 +305,8 @@ public class SubscriptionView implements
         return filter.matches(destination);
     }
 
+    @Override
+    public boolean isSlowConsumer() {
+        return subscription.isSlowConsumer();
+    }
 }

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java?rev=1140098&r1=1140097&r2=1140098&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java Mon Jun 27 10:56:56 2011
@@ -196,4 +196,13 @@ public interface SubscriptionViewMBean {
      */
     @MBeanInfo("Returns true if the subscription (which may be using wildcards) matches the given topic name")
     boolean isMatchingTopic(String topicName);
+
+    /**
+     * Returns true if the subscription is slow
+     *
+     * @return true if the subscription is slow
+     */
+    @MBeanInfo("Returns true if the subscription is slow")
+    boolean isSlowConsumer();
+
 }