org.apache.activemq.broker.jmx
public interface SubscriptionViewMBean
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getClientId() |
javax.management.ObjectName |
getConnection()
Returns the ObjectName of the Connection that created this Subscription.
|
java.lang.String |
getConnectionId() |
long |
getDequeueCounter() |
java.lang.String |
getDestinationName() |
long |
getDispatchedCounter() |
int |
getDispatchedQueueSize() |
long |
getEnqueueCounter() |
int |
getMaximumPendingMessageLimit() |
int |
getMessageCountAwaitingAcknowledge()
The same as the number of messages dispatched -
making it explicit
|
int |
getPendingQueueSize() |
int |
getPrefetchSize() |
byte |
getPriority() |
java.lang.String |
getSelector() |
long |
getSessionId() |
long |
getSubcriptionId() |
java.lang.String |
getSubcriptionName() |
java.lang.String |
getUserName()
Returns the User Name used to authorize creation of this Subscription.
|
boolean |
isActive() |
boolean |
isDestinationQueue() |
boolean |
isDestinationTemporary() |
boolean |
isDestinationTopic() |
boolean |
isDurable() |
boolean |
isExclusive() |
boolean |
isMatchingQueue(java.lang.String queueName)
Returns true if this subscription (which may be using wildcards) matches the given queue name
|
boolean |
isMatchingTopic(java.lang.String topicName)
Returns true if this subscription (which may be using wildcards) matches the given topic name
|
boolean |
isNoLocal() |
boolean |
isRetroactive() |
boolean |
isSlowConsumer()
Returns true if the subscription is slow
|
void |
setSelector(java.lang.String selector)
Attempts to change the current active selector on the subscription.
|
java.lang.String getClientId()
java.lang.String getConnectionId()
long getSessionId()
long getSubcriptionId()
java.lang.String getDestinationName()
java.lang.String getSelector()
void setSelector(java.lang.String selector) throws javax.jms.InvalidSelectorException, java.lang.UnsupportedOperationException
javax.jms.InvalidSelectorException
java.lang.UnsupportedOperationException
boolean isDestinationQueue()
boolean isDestinationTopic()
boolean isDestinationTemporary()
boolean isActive()
int getPendingQueueSize()
int getDispatchedQueueSize()
int getMessageCountAwaitingAcknowledge()
long getDispatchedCounter()
long getEnqueueCounter()
long getDequeueCounter()
int getPrefetchSize()
boolean isRetroactive()
boolean isExclusive()
boolean isDurable()
boolean isNoLocal()
int getMaximumPendingMessageLimit()
byte getPriority()
java.lang.String getSubcriptionName()
boolean isMatchingQueue(java.lang.String queueName)
queueName
- the JMS queue name to match againstboolean isMatchingTopic(java.lang.String topicName)
topicName
- the JMS topic name to match againstboolean isSlowConsumer()
java.lang.String getUserName()
javax.management.ObjectName getConnection()
Copyright © 2005-2014. All Rights Reserved.