diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java index 74004be9ab..53503e9112 100755 --- a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java @@ -305,4 +305,8 @@ public class SubscriptionView implements SubscriptionViewMBean { return filter.matches(destination); } + @Override + public boolean isSlowConsumer() { + return subscription.isSlowConsumer(); + } } diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java index 134f809ef3..39462c57ae 100755 --- a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java @@ -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(); + }