public class SubscriptionView extends Object implements SubscriptionViewMBean
Modifier and Type | Field and Description |
---|---|
protected String |
clientId |
protected Subscription |
subscription |
protected String |
userName |
Constructor and Description |
---|
SubscriptionView(String clientId,
String userName,
Subscription subs)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
gc()
The subscription should release as may references as it can to help the
garbage collector reclaim memory.
|
String |
getClientId() |
ObjectName |
getConnection()
Returns the ObjectName of the Connection that created this Subscription.
|
String |
getConnectionId() |
protected ConsumerInfo |
getConsumerInfo() |
long |
getDequeueCounter() |
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() |
String |
getSelector() |
long |
getSessionId() |
long |
getSubcriptionId() |
String |
getSubcriptionName() |
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(String queueName)
Returns true if this subscription (which may be using wildcards) matches the given queue name
|
boolean |
isMatchingTopic(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
|
boolean |
matchesDestination(ActiveMQDestination destination)
Return true if this subscription matches the given destination
|
void |
setSelector(String selector)
Attempts to change the current active selector on the subscription.
|
String |
toString() |
protected final Subscription subscription
protected final String clientId
protected final String userName
public SubscriptionView(String clientId, String userName, Subscription subs)
subs
- public String getClientId()
getClientId
in interface SubscriptionViewMBean
public ObjectName getConnection()
SubscriptionViewMBean
getConnection
in interface SubscriptionViewMBean
public String getConnectionId()
getConnectionId
in interface SubscriptionViewMBean
public long getSessionId()
getSessionId
in interface SubscriptionViewMBean
public long getSubcriptionId()
getSubcriptionId
in interface SubscriptionViewMBean
public String getDestinationName()
getDestinationName
in interface SubscriptionViewMBean
public String getSelector()
getSelector
in interface SubscriptionViewMBean
public void setSelector(String selector) throws javax.jms.InvalidSelectorException, UnsupportedOperationException
SubscriptionViewMBean
setSelector
in interface SubscriptionViewMBean
javax.jms.InvalidSelectorException
UnsupportedOperationException
public boolean isDestinationQueue()
isDestinationQueue
in interface SubscriptionViewMBean
public boolean isDestinationTopic()
isDestinationTopic
in interface SubscriptionViewMBean
public boolean isDestinationTemporary()
isDestinationTemporary
in interface SubscriptionViewMBean
public boolean isActive()
isActive
in interface SubscriptionViewMBean
public void gc()
public boolean isRetroactive()
isRetroactive
in interface SubscriptionViewMBean
public boolean isExclusive()
isExclusive
in interface SubscriptionViewMBean
public boolean isDurable()
isDurable
in interface SubscriptionViewMBean
public boolean isNoLocal()
isNoLocal
in interface SubscriptionViewMBean
public int getMaximumPendingMessageLimit()
getMaximumPendingMessageLimit
in interface SubscriptionViewMBean
public byte getPriority()
getPriority
in interface SubscriptionViewMBean
public String getSubcriptionName()
getSubcriptionName
in interface SubscriptionViewMBean
public int getPendingQueueSize()
getPendingQueueSize
in interface SubscriptionViewMBean
public int getDispatchedQueueSize()
getDispatchedQueueSize
in interface SubscriptionViewMBean
public int getMessageCountAwaitingAcknowledge()
SubscriptionViewMBean
getMessageCountAwaitingAcknowledge
in interface SubscriptionViewMBean
public long getDispatchedCounter()
getDispatchedCounter
in interface SubscriptionViewMBean
public long getEnqueueCounter()
getEnqueueCounter
in interface SubscriptionViewMBean
public long getDequeueCounter()
getDequeueCounter
in interface SubscriptionViewMBean
protected ConsumerInfo getConsumerInfo()
public int getPrefetchSize()
getPrefetchSize
in interface SubscriptionViewMBean
public boolean isMatchingQueue(String queueName)
SubscriptionViewMBean
isMatchingQueue
in interface SubscriptionViewMBean
queueName
- the JMS queue name to match againstpublic boolean isMatchingTopic(String topicName)
SubscriptionViewMBean
isMatchingTopic
in interface SubscriptionViewMBean
topicName
- the JMS topic name to match againstpublic boolean matchesDestination(ActiveMQDestination destination)
destination
- the destination to compare againstpublic boolean isSlowConsumer()
SubscriptionViewMBean
isSlowConsumer
in interface SubscriptionViewMBean
public String getUserName()
SubscriptionViewMBean
getUserName
in interface SubscriptionViewMBean
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.