org.apache.activemq.broker.jmx
Class InactiveDurableSubscriptionView

java.lang.Object
  extended by org.apache.activemq.broker.jmx.SubscriptionView
      extended by org.apache.activemq.broker.jmx.DurableSubscriptionView
          extended by org.apache.activemq.broker.jmx.InactiveDurableSubscriptionView
All Implemented Interfaces:
DurableSubscriptionViewMBean, SubscriptionViewMBean

public class InactiveDurableSubscriptionView
extends DurableSubscriptionView
implements DurableSubscriptionViewMBean


Field Summary
protected  SubscriptionInfo subscriptionInfo
           
 
Fields inherited from class org.apache.activemq.broker.jmx.DurableSubscriptionView
broker, brokerService, durableSub, subscriptionName
 
Fields inherited from class org.apache.activemq.broker.jmx.SubscriptionView
clientId, subscription, userName
 
Constructor Summary
InactiveDurableSubscriptionView(ManagedRegionBroker broker, BrokerService brokerService, String clientId, SubscriptionInfo subInfo, Subscription subscription)
          Constructor
 
Method Summary
 CompositeData[] browse()
          Browse messages for this durable subscriber
 TabularData browseAsTable()
          Browse messages for this durable subscriber
 void destroy()
          Destroys the durable subscription so that messages will no longer be stored for this subscription
protected  ConsumerInfo getConsumerInfo()
           
 String getDestinationName()
           
 String getSelector()
           
 long getSubcriptionId()
           
 String getSubscriptionName()
           
 boolean isActive()
           
 boolean isDestinationQueue()
           
 boolean isDestinationTemporary()
           
 boolean isDestinationTopic()
           
 String toString()
           
 
Methods inherited from class org.apache.activemq.broker.jmx.DurableSubscriptionView
cursorSize, doesCursorHaveMessagesBuffered, doesCursorHaveSpace, getCursorMemoryUsage, getCursorPercentUsage, isCursorFull
 
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, isNetwork, 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.DurableSubscriptionViewMBean
cursorSize, doesCursorHaveMessagesBuffered, doesCursorHaveSpace, getCursorMemoryUsage, getCursorPercentUsage, isCursorFull
 
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, isNetwork, isNoLocal, isRetroactive, isSlowConsumer, setSelector
 

Field Detail

subscriptionInfo

protected SubscriptionInfo subscriptionInfo
Constructor Detail

InactiveDurableSubscriptionView

public InactiveDurableSubscriptionView(ManagedRegionBroker broker,
                                       BrokerService brokerService,
                                       String clientId,
                                       SubscriptionInfo subInfo,
                                       Subscription subscription)
Constructor

Parameters:
broker -
clientId -
userName -
subInfo -
Method Detail

getSubcriptionId

public long getSubcriptionId()
Specified by:
getSubcriptionId in interface SubscriptionViewMBean
Overrides:
getSubcriptionId in class SubscriptionView
Returns:
the id of the Subscription

getDestinationName

public 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 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 CompositeData[] browse()
                       throws OpenDataException
Browse messages for this durable subscriber

Specified by:
browse in interface DurableSubscriptionViewMBean
Overrides:
browse in class DurableSubscriptionView
Returns:
messages
Throws:
OpenDataException

browseAsTable

public TabularData browseAsTable()
                          throws OpenDataException
Browse messages for this durable subscriber

Specified by:
browseAsTable in interface DurableSubscriptionViewMBean
Overrides:
browseAsTable in class DurableSubscriptionView
Returns:
messages
Throws:
OpenDataException

destroy

public void destroy()
             throws 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:
Exception

toString

public String toString()
Overrides:
toString in class DurableSubscriptionView
Returns:
pretty print

getSelector

public String getSelector()
Specified by:
getSelector in interface SubscriptionViewMBean
Overrides:
getSelector in class SubscriptionView
Returns:
the JMS selector on the current subscription


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.