Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Include the prefetch size in the JMX stats of a subscription 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397982 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-04-28 19:02:01 +00:00
parent d67246412d
commit f5f1366e4b
4 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
View File

@ -210,4 +210,10 @@ public class SubscriptionView implements SubscriptionViewMBean {
return "SubscriptionView: " + getClientId() + ":" + getConnectionId();
}
/**
*/
public int getPrefetchSize() {
return subscription != null ? subscription.getPrefetchSize() : 0;
}
}

4
activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java
View File

@ -101,4 +101,8 @@ public interface SubscriptionViewMBean{
*/
long getDequeueCounter();
/**
* @return the prefetch that has been configured for this subscriber
*/
public int getPrefetchSize();
}

4
activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java
View File

@ -150,4 +150,8 @@ abstract public class AbstractSubscription implements Subscription {
public void setObjectName(ObjectName objectName) {
this.objectName = objectName;
}
public int getPrefetchSize() {
return info.getPrefetchSize();
}
}

5
activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java
View File

@ -176,4 +176,9 @@ public interface Subscription {
*/
public void destroy();
/**
* @return the prefetch size that is configured for the subscription
*/
int getPrefetchSize();
}