svn commit: r397982 - in /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker: jmx/SubscriptionView.java jmx/SubscriptionViewMBean.java region/AbstractSubscription.java region/Subscription.java

[chirino]

Author: chirino
Date: Fri Apr 28 12:02:01 2006
New Revision: 397982

URL: http://svn.apache.org/viewcvs?rev=397982&view=rev
Log:
Include the prefetch size in the JMX stats of a subscription

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

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java?rev=397982&r1=397981&r2=397982&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
 Fri Apr 28 12:02:01 2006
@@ -210,4 +210,10 @@
         return "SubscriptionView: " + getClientId()  + ":" +  
getConnectionId();
     }
 
+    /**
+     */
+    public int getPrefetchSize() {
+        return subscription != null ? subscription.getPrefetchSize() : 0;
+    }
+
 }

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java?rev=397982&r1=397981&r2=397982&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java
 Fri Apr 28 12:02:01 2006
@@ -101,4 +101,8 @@
      */
     long getDequeueCounter();
 
+    /**
+     * @return the prefetch that has been configured for this subscriber
+     */
+    public int getPrefetchSize();
 }

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java?rev=397982&r1=397981&r2=397982&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java
 Fri Apr 28 12:02:01 2006
@@ -150,4 +150,8 @@
     public void setObjectName(ObjectName objectName) {
         this.objectName = objectName;
     }
+    
+    public int getPrefetchSize() {
+        return info.getPrefetchSize();
+    }
 }

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java?rev=397982&r1=397981&r2=397982&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java
 Fri Apr 28 12:02:01 2006
@@ -176,4 +176,9 @@
      */
     public void destroy();
 
+    /**
+     * @return the prefetch size that is configured for the subscription
+     */
+    int getPrefetchSize();
+
 }