public class JMSTopicControlImpl extends StandardMBean implements TopicControl
| Constructor and Description |
|---|
JMSTopicControlImpl(ActiveMQDestination topic,
JMSServerManager jmsServerManager,
AddressControl addressControl,
org.apache.activemq.artemis.core.server.management.ManagementService managementService) |
| Modifier and Type | Method and Description |
|---|---|
void |
addBinding(String binding)
Add the Registry binding to this destination
|
int |
countMessagesForSubscription(String clientID,
String subscriptionName,
String filterStr)
Counts the number of messages in the subscription specified by the specified client ID and subscription name.
|
static String |
createFilterFromJMSSelector(String selectorStr) |
void |
dropAllSubscriptions()
Drops all subscriptions.
|
void |
dropDurableSubscription(String clientID,
String subscriptionName)
Drops the subscription specified by the specified client ID and subscription name.
|
String |
getAddress()
Returns the address corresponding to this destination.
|
int |
getDeliveringCount()
Returns the number of messages that this queue is currently delivering to its consumers.
|
int |
getDurableMessageCount()
Returns the number of messages for all durable subscribers for this topic.
|
int |
getDurableSubscriptionCount()
Returns the number of durable subscribers for this topic.
|
MBeanInfo |
getMBeanInfo() |
long |
getMessageCount()
Returns the number of messages currently in this destination.
|
long |
getMessagesAdded()
Returns the number of messages added to this queue since it was created.
|
String |
getName()
Returns the name of this destination.
|
int |
getNonDurableMessageCount()
Returns the number of messages for all non-durable subscribers for this topic.
|
int |
getNonDurableSubscriptionCount()
Returns the number of non-durable subscribers for this topic.
|
String[] |
getRegistryBindings()
Returns the Registry bindings associated with this topic.
|
int |
getSubscriptionCount()
Returns the number of (durable and non-durable) subscribers for this topic.
|
boolean |
isTemporary()
Returns whether this destination is temporary.
|
Object[] |
listAllSubscriptions()
Lists all the subscriptions for this topic (both durable and non-durable).
|
String |
listAllSubscriptionsAsJSON()
Lists all the subscriptions for this topic (both durable and non-durable) using JSON serialization.
|
Object[] |
listDurableSubscriptions()
Lists all the durable subscriptions for this topic.
|
String |
listDurableSubscriptionsAsJSON()
Lists all the durable subscriptions using JSON serialization.
|
Map<String,Object>[] |
listMessagesForSubscription(String queueName)
Lists all the messages in this queue matching the specified queue representing the subscription.
|
String |
listMessagesForSubscriptionAsJSON(String queueName)
Lists all the messages in this queue matching the specified queue representing the subscription using JSON serialization.
|
Object[] |
listNonDurableSubscriptions()
Lists all the non-durable subscriptions for this topic.
|
String |
listNonDurableSubscriptionsAsJSON()
Lists all the non-durable subscriptions using JSON serialization.
|
int |
removeMessages(String filterStr)
Removed all the messages which matches the specified JMS filter from this destination.
|
cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementationpublic JMSTopicControlImpl(ActiveMQDestination topic, JMSServerManager jmsServerManager, AddressControl addressControl, org.apache.activemq.artemis.core.server.management.ManagementService managementService) throws Exception
Exceptionpublic static String createFilterFromJMSSelector(String selectorStr) throws ActiveMQException
ActiveMQExceptionpublic void addBinding(String binding) throws Exception
TopicControladdBinding in interface TopicControlExceptionpublic String[] getRegistryBindings()
TopicControlgetRegistryBindings in interface TopicControlpublic String getName()
DestinationControlgetName in interface DestinationControlpublic boolean isTemporary()
DestinationControlisTemporary in interface DestinationControlpublic String getAddress()
DestinationControlgetAddress in interface DestinationControlpublic long getMessageCount()
DestinationControlgetMessageCount in interface DestinationControlpublic int getDeliveringCount()
DestinationControlgetDeliveringCount in interface DestinationControlpublic long getMessagesAdded()
DestinationControlgetMessagesAdded in interface DestinationControlpublic int getDurableMessageCount()
TopicControlgetDurableMessageCount in interface TopicControlpublic int getNonDurableMessageCount()
TopicControlgetNonDurableMessageCount in interface TopicControlpublic int getSubscriptionCount()
TopicControlgetSubscriptionCount in interface TopicControlpublic int getDurableSubscriptionCount()
TopicControlgetDurableSubscriptionCount in interface TopicControlpublic int getNonDurableSubscriptionCount()
TopicControlgetNonDurableSubscriptionCount in interface TopicControlpublic Object[] listAllSubscriptions()
TopicControllistAllSubscriptions in interface TopicControlpublic String listAllSubscriptionsAsJSON() throws Exception
TopicControlSubscriptionInfo.from(String).listAllSubscriptionsAsJSON in interface TopicControlExceptionpublic Object[] listDurableSubscriptions()
TopicControllistDurableSubscriptions in interface TopicControlpublic String listDurableSubscriptionsAsJSON() throws Exception
TopicControlSubscriptionInfo.from(String).listDurableSubscriptionsAsJSON in interface TopicControlExceptionpublic Object[] listNonDurableSubscriptions()
TopicControllistNonDurableSubscriptions in interface TopicControlpublic String listNonDurableSubscriptionsAsJSON() throws Exception
TopicControlSubscriptionInfo.from(String).listNonDurableSubscriptionsAsJSON in interface TopicControlExceptionpublic Map<String,Object>[] listMessagesForSubscription(String queueName) throws Exception
TopicControllistMessagesForSubscription in interface TopicControlExceptionpublic String listMessagesForSubscriptionAsJSON(String queueName) throws Exception
TopicControllistMessagesForSubscriptionAsJSON in interface TopicControlExceptionpublic int countMessagesForSubscription(String clientID, String subscriptionName, String filterStr) throws Exception
TopicControlnull or an empty filter will count all messages from this queue.countMessagesForSubscription in interface TopicControlExceptionpublic int removeMessages(String filterStr) throws Exception
DestinationControlnull or an empty filter will remove all messages from this destination.removeMessages in interface DestinationControlExceptionpublic void dropDurableSubscription(String clientID, String subscriptionName) throws Exception
TopicControldropDurableSubscription in interface TopicControlExceptionpublic void dropAllSubscriptions()
throws Exception
TopicControldropAllSubscriptions in interface TopicControlExceptionpublic MBeanInfo getMBeanInfo()
getMBeanInfo in interface DynamicMBeangetMBeanInfo in class StandardMBeanCopyright © 2018 The Apache Software Foundation. All rights reserved.