[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-commits
Subject:    svn commit: r397982 - in
From:       chirino () apache ! org
Date:       2006-04-28 19:02:03
Message-ID: 20060428190204.39945.qmail () minotaur ! apache ! org
[Download RAW message or body]

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/jav \
a/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/jav \
a/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/jav \
a/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/jav \
a/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();
+
 }


[prev in list] [next in list] [prev in thread] [next in thread]