public class InactiveDurableSubscriptionView extends DurableSubscriptionView implements DurableSubscriptionViewMBean
Modifier and Type | Field and Description |
---|---|
protected SubscriptionInfo |
subscriptionInfo |
broker, brokerService, durableSub, subscriptionName
clientId, subscription, userName
Constructor and Description |
---|
InactiveDurableSubscriptionView(ManagedRegionBroker broker,
BrokerService brokerService,
String clientId,
SubscriptionInfo subInfo,
Subscription subscription)
Constructor
|
Modifier and Type | Method and Description |
---|---|
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 |
getSubscriptionId() |
String |
getSubscriptionName() |
boolean |
isActive() |
boolean |
isDestinationQueue() |
boolean |
isDestinationTemporary() |
boolean |
isDestinationTopic() |
void |
removeMessage(String messageId)
Removes a message from the durable subscription.
|
String |
toString() |
cursorSize, doesCursorHaveMessagesBuffered, doesCursorHaveSpace, getCursorMemoryUsage, getCursorPercentUsage, isCursorFull
gc, getClientId, getConnection, getConnectionId, getConsumedCount, getDequeueCounter, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSessionId, getSubcriptionId, getSubcriptionName, getUserName, isDispatchAsync, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNetwork, isNoLocal, isRetroactive, isSlowConsumer, matchesDestination, resetStatistics, setSelector
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
cursorSize, doesCursorHaveMessagesBuffered, doesCursorHaveSpace, getCursorMemoryUsage, getCursorPercentUsage, isCursorFull
getClientId, getConnection, getConnectionId, getConsumedCount, getDequeueCounter, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getMaximumPendingMessageLimit, getMessageCountAwaitingAcknowledge, getPendingQueueSize, getPrefetchSize, getPriority, getSessionId, getSubcriptionId, getSubcriptionName, getUserName, isDispatchAsync, isDurable, isExclusive, isMatchingQueue, isMatchingTopic, isNetwork, isNoLocal, isRetroactive, isSlowConsumer, resetStatistics, setSelector
protected SubscriptionInfo subscriptionInfo
public InactiveDurableSubscriptionView(ManagedRegionBroker broker, BrokerService brokerService, String clientId, SubscriptionInfo subInfo, Subscription subscription)
broker
- clientId
- userName
- subInfo
- public long getSubscriptionId()
getSubscriptionId
in interface SubscriptionViewMBean
getSubscriptionId
in class SubscriptionView
public String getDestinationName()
getDestinationName
in interface SubscriptionViewMBean
getDestinationName
in class SubscriptionView
public boolean isDestinationQueue()
isDestinationQueue
in interface SubscriptionViewMBean
isDestinationQueue
in class SubscriptionView
public boolean isDestinationTopic()
isDestinationTopic
in interface SubscriptionViewMBean
isDestinationTopic
in class SubscriptionView
public boolean isDestinationTemporary()
isDestinationTemporary
in interface SubscriptionViewMBean
isDestinationTemporary
in class SubscriptionView
public String getSubscriptionName()
getSubscriptionName
in interface DurableSubscriptionViewMBean
getSubscriptionName
in interface SubscriptionViewMBean
getSubscriptionName
in class DurableSubscriptionView
public boolean isActive()
isActive
in interface SubscriptionViewMBean
isActive
in class DurableSubscriptionView
protected ConsumerInfo getConsumerInfo()
getConsumerInfo
in class SubscriptionView
public CompositeData[] browse() throws OpenDataException
browse
in interface DurableSubscriptionViewMBean
browse
in class DurableSubscriptionView
OpenDataException
public TabularData browseAsTable() throws OpenDataException
browseAsTable
in interface DurableSubscriptionViewMBean
browseAsTable
in class DurableSubscriptionView
OpenDataException
public void destroy() throws Exception
destroy
in interface DurableSubscriptionViewMBean
destroy
in class DurableSubscriptionView
Exception
public String toString()
toString
in class DurableSubscriptionView
public String getSelector()
getSelector
in interface SubscriptionViewMBean
getSelector
in class SubscriptionView
public void removeMessage(String messageId) throws Exception
DurableSubscriptionViewMBean
removeMessage
in interface DurableSubscriptionViewMBean
removeMessage
in class DurableSubscriptionView
Exception
Copyright © 2005–2020 FuseSource, Corp.. All rights reserved.