public class DurableSubscriptionView extends SubscriptionView implements DurableSubscriptionViewMBean
Modifier and Type | Field and Description |
---|---|
protected ManagedRegionBroker |
broker |
protected BrokerService |
brokerService |
protected DurableTopicSubscription |
durableSub |
protected String |
subscriptionName |
clientId, subscription, userName
Constructor and Description |
---|
DurableSubscriptionView(ManagedRegionBroker broker,
BrokerService brokerService,
String clientId,
String userName,
Subscription sub)
Constructor
|
Modifier and Type | Method and Description |
---|---|
CompositeData[] |
browse()
Browse messages for this durable subscriber
|
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() |
String |
getSubscriptionName() |
boolean |
isActive() |
boolean |
isCursorFull() |
void |
removeMessage(String messageId)
Removes a message from the durable subscription.
|
String |
toString() |
gc, getClientId, getConnection, getConnectionId, getConsumedCount, getConsumerInfo, getDequeueCounter, getDestinationName, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSelector, getSessionId, getSubscriptionId, getUserName, isDestinationQueue, isDestinationTemporary, isDestinationTopic, isDispatchAsync, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNetwork, isNoLocal, isRetroactive, isSlowConsumer, matchesDestination, resetStatistics, setSelector
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getClientId, getConnection, getConnectionId, getConsumedCount, getDequeueCounter, getDestinationName, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSelector, getSessionId, getSubscriptionId, getUserName, isDestinationQueue, isDestinationTemporary, isDestinationTopic, isDispatchAsync, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNetwork, isNoLocal, isRetroactive, isSlowConsumer, resetStatistics, setSelector
protected ManagedRegionBroker broker
protected BrokerService brokerService
protected String subscriptionName
protected DurableTopicSubscription durableSub
public DurableSubscriptionView(ManagedRegionBroker broker, BrokerService brokerService, String clientId, String userName, Subscription sub)
clientId
- sub
- public String getSubscriptionName()
getSubscriptionName
in interface DurableSubscriptionViewMBean
getSubscriptionName
in interface SubscriptionViewMBean
getSubscriptionName
in class SubscriptionView
public CompositeData[] browse() throws OpenDataException
browse
in interface DurableSubscriptionViewMBean
OpenDataException
public TabularData browseAsTable() throws OpenDataException
browseAsTable
in interface DurableSubscriptionViewMBean
OpenDataException
public void destroy() throws Exception
destroy
in interface DurableSubscriptionViewMBean
Exception
public String toString()
toString
in class SubscriptionView
public int cursorSize()
cursorSize
in interface DurableSubscriptionViewMBean
public void removeMessage(String messageId) throws Exception
DurableSubscriptionViewMBean
removeMessage
in interface DurableSubscriptionViewMBean
Exception
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–2016 The Apache Software Foundation. All rights reserved.