org.apache.activemq.broker.jmx
Class InactiveDurableSubscriptionView
java.lang.Object
org.apache.activemq.broker.jmx.SubscriptionView
org.apache.activemq.broker.jmx.DurableSubscriptionView
org.apache.activemq.broker.jmx.InactiveDurableSubscriptionView
- All Implemented Interfaces:
- DurableSubscriptionViewMBean, SubscriptionViewMBean
public class InactiveDurableSubscriptionView
- extends DurableSubscriptionView
- implements DurableSubscriptionViewMBean
Methods inherited from class org.apache.activemq.broker.jmx.SubscriptionView |
gc, getClientId, getConnection, getConnectionId, getDequeueCounter, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSessionId, getSubcriptionName, getUserName, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNoLocal, isRetroactive, isSlowConsumer, matchesDestination, setSelector |
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, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSessionId, getSubcriptionName, getUserName, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNoLocal, isRetroactive, isSlowConsumer, setSelector |
subscriptionInfo
protected SubscriptionInfo subscriptionInfo
InactiveDurableSubscriptionView
public InactiveDurableSubscriptionView(ManagedRegionBroker broker,
java.lang.String clientId,
SubscriptionInfo subInfo,
Subscription subscription)
- Constructor
- Parameters:
broker
- clientId
- userName
- subInfo
-
getSubcriptionId
public long getSubcriptionId()
- Specified by:
getSubcriptionId
in interface SubscriptionViewMBean
- Overrides:
getSubcriptionId
in class SubscriptionView
- Returns:
- the id of the Subscription
getDestinationName
public java.lang.String getDestinationName()
- Specified by:
getDestinationName
in interface SubscriptionViewMBean
- Overrides:
getDestinationName
in class SubscriptionView
- Returns:
- the destination name
isDestinationQueue
public boolean isDestinationQueue()
- Specified by:
isDestinationQueue
in interface SubscriptionViewMBean
- Overrides:
isDestinationQueue
in class SubscriptionView
- Returns:
- true if the destination is a Queue
isDestinationTopic
public boolean isDestinationTopic()
- Specified by:
isDestinationTopic
in interface SubscriptionViewMBean
- Overrides:
isDestinationTopic
in class SubscriptionView
- Returns:
- true of the destination is a Topic
isDestinationTemporary
public boolean isDestinationTemporary()
- Specified by:
isDestinationTemporary
in interface SubscriptionViewMBean
- Overrides:
isDestinationTemporary
in class SubscriptionView
- Returns:
- true if the destination is temporary
getSubscriptionName
public java.lang.String getSubscriptionName()
- Specified by:
getSubscriptionName
in interface DurableSubscriptionViewMBean
- Overrides:
getSubscriptionName
in class DurableSubscriptionView
- Returns:
- name of the durable consumer
isActive
public boolean isActive()
- Specified by:
isActive
in interface SubscriptionViewMBean
- Overrides:
isActive
in class DurableSubscriptionView
- Returns:
- true if the subscriber is active
getConsumerInfo
protected ConsumerInfo getConsumerInfo()
- Overrides:
getConsumerInfo
in class SubscriptionView
browse
public javax.management.openmbean.CompositeData[] browse()
throws javax.management.openmbean.OpenDataException
- Browse messages for this durable subscriber
- Specified by:
browse
in interface DurableSubscriptionViewMBean
- Overrides:
browse
in class DurableSubscriptionView
- Returns:
- messages
- Throws:
javax.management.openmbean.OpenDataException
browseAsTable
public javax.management.openmbean.TabularData browseAsTable()
throws javax.management.openmbean.OpenDataException
- Browse messages for this durable subscriber
- Specified by:
browseAsTable
in interface DurableSubscriptionViewMBean
- Overrides:
browseAsTable
in class DurableSubscriptionView
- Returns:
- messages
- Throws:
javax.management.openmbean.OpenDataException
destroy
public void destroy()
throws java.lang.Exception
- Destroys the durable subscription so that messages will no longer be
stored for this subscription
- Specified by:
destroy
in interface DurableSubscriptionViewMBean
- Overrides:
destroy
in class DurableSubscriptionView
- Throws:
java.lang.Exception
toString
public java.lang.String toString()
- Overrides:
toString
in class DurableSubscriptionView
- Returns:
- pretty print
getSelector
public java.lang.String getSelector()
- Specified by:
getSelector
in interface SubscriptionViewMBean
- Overrides:
getSelector
in class SubscriptionView
- Returns:
- the JMS selector on the current subscription
Copyright © 2005-2015. All Rights Reserved.