public class JMSTopicControlImpl extends StandardMBean implements TopicControl
Constructor and Description |
---|
JMSTopicControlImpl(ActiveMQDestination topic,
JMSServerManager jmsServerManager,
AddressControl addressControl,
ManagementService managementService) |
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, setImplementation
public JMSTopicControlImpl(ActiveMQDestination topic, JMSServerManager jmsServerManager, AddressControl addressControl, ManagementService managementService) throws Exception
Exception
public static String createFilterFromJMSSelector(String selectorStr) throws ActiveMQException
ActiveMQException
public void addBinding(String binding) throws Exception
addBinding
in interface TopicControl
Exception
public String[] getRegistryBindings()
getRegistryBindings
in interface TopicControl
public String getName()
getName
in interface DestinationControl
public boolean isTemporary()
isTemporary
in interface DestinationControl
public String getAddress()
getAddress
in interface DestinationControl
public long getMessageCount()
getMessageCount
in interface DestinationControl
public int getDeliveringCount()
getDeliveringCount
in interface DestinationControl
public long getMessagesAdded()
getMessagesAdded
in interface DestinationControl
public int getDurableMessageCount()
getDurableMessageCount
in interface TopicControl
public int getNonDurableMessageCount()
getNonDurableMessageCount
in interface TopicControl
public int getSubscriptionCount()
getSubscriptionCount
in interface TopicControl
public int getDurableSubscriptionCount()
getDurableSubscriptionCount
in interface TopicControl
public int getNonDurableSubscriptionCount()
getNonDurableSubscriptionCount
in interface TopicControl
public Object[] listAllSubscriptions()
listAllSubscriptions
in interface TopicControl
public String listAllSubscriptionsAsJSON() throws Exception
listAllSubscriptionsAsJSON
in interface TopicControl
Exception
public Object[] listDurableSubscriptions()
listDurableSubscriptions
in interface TopicControl
public String listDurableSubscriptionsAsJSON() throws Exception
listDurableSubscriptionsAsJSON
in interface TopicControl
Exception
public Object[] listNonDurableSubscriptions()
listNonDurableSubscriptions
in interface TopicControl
public String listNonDurableSubscriptionsAsJSON() throws Exception
listNonDurableSubscriptionsAsJSON
in interface TopicControl
Exception
public Map<String,Object>[] listMessagesForSubscription(String queueName) throws Exception
listMessagesForSubscription
in interface TopicControl
Exception
public String listMessagesForSubscriptionAsJSON(String queueName) throws Exception
listMessagesForSubscriptionAsJSON
in interface TopicControl
Exception
public int countMessagesForSubscription(String clientID, String subscriptionName, String filterStr) throws Exception
countMessagesForSubscription
in interface TopicControl
Exception
public int removeMessages(String filterStr) throws Exception
removeMessages
in interface DestinationControl
Exception
public void dropDurableSubscription(String clientID, String subscriptionName) throws Exception
dropDurableSubscription
in interface TopicControl
Exception
public void dropAllSubscriptions() throws Exception
dropAllSubscriptions
in interface TopicControl
Exception
public MBeanInfo getMBeanInfo()
getMBeanInfo
in interface DynamicMBean
getMBeanInfo
in class StandardMBean
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.