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


Field Summary
 
Fields inherited from class org.apache.activemq.broker.jmx.SubscriptionView
clientId, subscription, userName
 
Constructor Summary
TopicSubscriptionView(String clientId, String userName, TopicSubscription subs)
           
 
Method Summary
 int getDiscardedCount()
           
 int getMaximumPendingQueueSize()
           
protected  TopicSubscription getTopicSubscription()
           
 boolean isActive()
           
 void setMaximumPendingQueueSize(int max)
           
 
Methods inherited from class org.apache.activemq.broker.jmx.SubscriptionView
gc, getClientId, getConnection, getConnectionId, getConsumerInfo, getDequeueCounter, getDestinationName, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSelector, getSessionId, getSubcriptionId, getSubcriptionName, getUserName, isDestinationQueue, isDestinationTemporary, isDestinationTopic, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNetwork, isNoLocal, isRetroactive, isSlowConsumer, matchesDestination, 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, getConnection, getConnectionId, getDequeueCounter, getDestinationName, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSelector, getSessionId, getSubcriptionId, getSubcriptionName, getUserName, isDestinationQueue, isDestinationTemporary, isDestinationTopic, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNetwork, isNoLocal, isRetroactive, isSlowConsumer, setSelector
 

Constructor Detail

TopicSubscriptionView

public TopicSubscriptionView(String clientId,
                             String userName,
                             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

isActive

public boolean isActive()
Specified by:
isActive in interface SubscriptionViewMBean
Overrides:
isActive in class SubscriptionView
Returns:
true if the subscriber is active


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.