org.apache.activemq.broker.jmx
Class TopicSubscriptionView

java.lang.Object
  extended by org.apache.activemq.broker.jmx.SubscriptionView
      extended by org.apache.activemq.broker.jmx.TopicSubscriptionView
All Implemented Interfaces:
SubscriptionViewMBean, TopicSubscriptionViewMBean

public class TopicSubscriptionView
extends SubscriptionView
implements TopicSubscriptionViewMBean

Version:
$Revision: 426366 $

Field Summary
 
Fields inherited from class org.apache.activemq.broker.jmx.SubscriptionView
clientId, subscription
 
Constructor Summary
TopicSubscriptionView(java.lang.String clientId, TopicSubscription subs)
           
 
Method Summary
 int getDiscardedCount()
           
 int getMaximumPendingQueueSize()
           
protected  TopicSubscription getTopicSubscription()
           
 void setMaximumPendingQueueSize(int max)
           
 
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 class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
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
 

Constructor Detail

TopicSubscriptionView

public TopicSubscriptionView(java.lang.String clientId,
                             TopicSubscription subs)
Method Detail

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 © 2009 Apache Software Foundation. All Rights Reserved.