org.apache.activemq.broker.jmx
Class TopicSubscriptionView
java.lang.Object
org.apache.activemq.broker.jmx.SubscriptionView
org.apache.activemq.broker.jmx.TopicSubscriptionView
- All Implemented Interfaces:
- SubscriptionViewMBean, TopicSubscriptionViewMBean
public class TopicSubscriptionView
- extends SubscriptionView
- implements TopicSubscriptionViewMBean
- Version:
- $Revision: 426366 $
Methods inherited from class org.apache.activemq.broker.jmx.SubscriptionView |
gc, getClientId, getConnectionId, getConsumerInfo, getDequeueCounter, getDestinationName, getDispachedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getPendingQueueSize, getPrefetchSize, getPriority, getSelector, getSessionId, getSubcriptionId, getSubcriptionName, isActive, isDestinationQueue, isDestinationTemporary, isDestinationTopic, isDurable, isExclusive, isNoLocal, isRetroactive, setSelector, toString |
Methods inherited from interface org.apache.activemq.broker.jmx.SubscriptionViewMBean |
getClientId, getConnectionId, getDequeueCounter, getDestinationName, getDispachedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getPendingQueueSize, getPrefetchSize, getPriority, getSelector, getSessionId, getSubcriptionId, getSubcriptionName, isActive, isDestinationQueue, isDestinationTemporary, isDestinationTopic, isDurable, isExclusive, isNoLocal, isRetroactive, setSelector |
TopicSubscriptionView
public TopicSubscriptionView(String clientId,
TopicSubscription subs)
getTopicSubscription
protected TopicSubscription getTopicSubscription()
getDiscardedCount
public int getDiscardedCount()
- Specified by:
getDiscardedCount
in interface TopicSubscriptionViewMBean
- Returns:
- the number of messages discarded due to being a slow consumer
getMaximumPendingQueueSize
public int getMaximumPendingQueueSize()
- Specified by:
getMaximumPendingQueueSize
in interface TopicSubscriptionViewMBean
- Returns:
- the maximun number of messages that can be pending.
setMaximumPendingQueueSize
public void setMaximumPendingQueueSize(int max)
- Specified by:
setMaximumPendingQueueSize
in interface TopicSubscriptionViewMBean
Copyright © 2011 Apache Software Foundation. All Rights Reserved.