activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r1140098 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx: SubscriptionView.java SubscriptionViewMBean.java
Date Mon, 27 Jun 2011 10:56:57 GMT
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();
+
 }



Mime
View raw message