From 9899dff93da37b089177f46166e83928eec742dd Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Thu, 3 Jan 2008 10:03:19 +0000 Subject: [PATCH] nake inflight message count a little more explicit git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@608414 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/broker/jmx/SubscriptionView.java | 4 ++++ .../apache/activemq/broker/jmx/SubscriptionViewMBean.java | 7 +++++++ 2 files changed, 11 insertions(+) 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 aa95e7320e..05fea89208 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 @@ -233,6 +233,10 @@ public class SubscriptionView implements SubscriptionViewMBean { public int getDispatchedQueueSize() { return subscription != null ? subscription.getDispatchedQueueSize() : 0; } + + public int getMessageCountAwaitingAcknowledge() { + return getDispatchedQueueSize(); + } /** * @return number of messages that matched the subscription 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 4aa684be44..c6d58829b0 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 @@ -88,6 +88,13 @@ public interface SubscriptionViewMBean { * @return number of messages dispatched */ int getDispatchedQueueSize(); + + /** + * The same as the number of messages dispatched - + * making it explicit + * @return + */ + int getMessageCountAwaitingAcknowledge(); /** * @return number of messages that matched the subscription