public class DurableSubscriptionView extends SubscriptionView implements DurableSubscriptionViewMBean
Modifier and Type | Field and Description |
---|---|
protected ManagedRegionBroker |
broker |
protected DurableTopicSubscription |
durableSub |
protected java.lang.String |
subscriptionName |
clientId, subscription
Constructor and Description |
---|
DurableSubscriptionView(ManagedRegionBroker broker,
java.lang.String clientId,
Subscription sub)
Constructor
|
Modifier and Type | Method and Description |
---|---|
javax.management.openmbean.CompositeData[] |
browse()
Browse messages for this durable subscriber
|
javax.management.openmbean.TabularData |
browseAsTable()
Browse messages for this durable subscriber
|
int |
cursorSize() |
void |
destroy()
Destroys the durable subscription so that messages will no longer be
stored for this subscription
|
boolean |
doesCursorHaveMessagesBuffered() |
boolean |
doesCursorHaveSpace() |
long |
getCursorMemoryUsage() |
int |
getCursorPercentUsage() |
java.lang.String |
getSubscriptionName() |
boolean |
isActive() |
boolean |
isCursorFull() |
java.lang.String |
toString() |
gc, getClientId, getConnectionId, getConsumerInfo, getDequeueCounter, getDestinationName, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSelector, getSessionId, getSubcriptionId, getSubcriptionName, isDestinationQueue, isDestinationTemporary, isDestinationTopic, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNoLocal, isRetroactive, matchesDestination, setSelector
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getClientId, getConnectionId, getDequeueCounter, getDestinationName, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSelector, getSessionId, getSubcriptionId, getSubcriptionName, isDestinationQueue, isDestinationTemporary, isDestinationTopic, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNoLocal, isRetroactive, setSelector
protected ManagedRegionBroker broker
protected java.lang.String subscriptionName
protected DurableTopicSubscription durableSub
public DurableSubscriptionView(ManagedRegionBroker broker, java.lang.String clientId, Subscription sub)
clientId
- sub
- public java.lang.String getSubscriptionName()
getSubscriptionName
in interface DurableSubscriptionViewMBean
public javax.management.openmbean.CompositeData[] browse() throws javax.management.openmbean.OpenDataException
browse
in interface DurableSubscriptionViewMBean
javax.management.openmbean.OpenDataException
public javax.management.openmbean.TabularData browseAsTable() throws javax.management.openmbean.OpenDataException
browseAsTable
in interface DurableSubscriptionViewMBean
javax.management.openmbean.OpenDataException
public void destroy() throws java.lang.Exception
destroy
in interface DurableSubscriptionViewMBean
java.lang.Exception
public java.lang.String toString()
toString
in class SubscriptionView
public int cursorSize()
cursorSize
in interface DurableSubscriptionViewMBean
public boolean doesCursorHaveMessagesBuffered()
doesCursorHaveMessagesBuffered
in interface DurableSubscriptionViewMBean
public boolean doesCursorHaveSpace()
doesCursorHaveSpace
in interface DurableSubscriptionViewMBean
public long getCursorMemoryUsage()
getCursorMemoryUsage
in interface DurableSubscriptionViewMBean
public int getCursorPercentUsage()
getCursorPercentUsage
in interface DurableSubscriptionViewMBean
public boolean isCursorFull()
isCursorFull
in interface DurableSubscriptionViewMBean
public boolean isActive()
isActive
in interface SubscriptionViewMBean
isActive
in class SubscriptionView
Copyright © 2005-2012. All Rights Reserved.