org.hornetq.jms.management.impl
Class JMSTopicControlImpl

java.lang.Object
  extended by javax.management.StandardMBean
      extended by org.hornetq.jms.management.impl.JMSTopicControlImpl
All Implemented Interfaces:
DynamicMBean, MBeanRegistration, DestinationControl, TopicControl

public class JMSTopicControlImpl
extends StandardMBean
implements TopicControl

Author:
Jeff Mesnil

Constructor Summary
JMSTopicControlImpl(HornetQDestination topic, JMSServerManager jmsServerManager, AddressControl addressControl, org.hornetq.core.server.management.ManagementService managementService)
           
 
Method Summary
 void addJNDI(String jndi)
           
 int countMessagesForSubscription(String clientID, String subscriptionName, String filterStr)
           
static String createFilterFromJMSSelector(String selectorStr)
           
 void dropAllSubscriptions()
           
 void dropDurableSubscription(String clientID, String subscriptionName)
           
 String getAddress()
           
 int getDeliveringCount()
           
 int getDurableMessageCount()
           
 int getDurableSubscriptionCount()
           
 String[] getJNDIBindings()
           
 MBeanInfo getMBeanInfo()
           
 long getMessageCount()
           
 long getMessagesAdded()
           
 String getName()
           
 int getNonDurableMessageCount()
           
 int getNonDurableSubscriptionCount()
           
 int getSubscriptionCount()
           
 boolean isTemporary()
           
 Object[] listAllSubscriptions()
           
 String listAllSubscriptionsAsJSON()
           
 Object[] listDurableSubscriptions()
           
 String listDurableSubscriptionsAsJSON()
           
 Map<String,Object>[] listMessagesForSubscription(String queueName)
           
 String listMessagesForSubscriptionAsJSON(String queueName)
           
 Object[] listNonDurableSubscriptions()
           
 String listNonDurableSubscriptionsAsJSON()
           
 void removeJNDI(String jndi)
           
 int removeMessages(String filterStr)
           
 
Methods inherited from class javax.management.StandardMBean
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JMSTopicControlImpl

public JMSTopicControlImpl(HornetQDestination topic,
                           JMSServerManager jmsServerManager,
                           AddressControl addressControl,
                           org.hornetq.core.server.management.ManagementService managementService)
                    throws Exception
Throws:
Exception
Method Detail

createFilterFromJMSSelector

public static String createFilterFromJMSSelector(String selectorStr)
                                          throws HornetQException
Throws:
HornetQException

addJNDI

public void addJNDI(String jndi)
             throws Exception
Specified by:
addJNDI in interface TopicControl
Throws:
Exception

removeJNDI

public void removeJNDI(String jndi)
                throws Exception
Throws:
Exception

getJNDIBindings

public String[] getJNDIBindings()
Specified by:
getJNDIBindings in interface TopicControl

getName

public String getName()
Specified by:
getName in interface DestinationControl

isTemporary

public boolean isTemporary()
Specified by:
isTemporary in interface DestinationControl

getAddress

public String getAddress()
Specified by:
getAddress in interface DestinationControl

getMessageCount

public long getMessageCount()
Specified by:
getMessageCount in interface DestinationControl

getDeliveringCount

public int getDeliveringCount()
Specified by:
getDeliveringCount in interface DestinationControl

getMessagesAdded

public long getMessagesAdded()
Specified by:
getMessagesAdded in interface DestinationControl

getDurableMessageCount

public int getDurableMessageCount()
Specified by:
getDurableMessageCount in interface TopicControl

getNonDurableMessageCount

public int getNonDurableMessageCount()
Specified by:
getNonDurableMessageCount in interface TopicControl

getSubscriptionCount

public int getSubscriptionCount()
Specified by:
getSubscriptionCount in interface TopicControl

getDurableSubscriptionCount

public int getDurableSubscriptionCount()
Specified by:
getDurableSubscriptionCount in interface TopicControl

getNonDurableSubscriptionCount

public int getNonDurableSubscriptionCount()
Specified by:
getNonDurableSubscriptionCount in interface TopicControl

listAllSubscriptions

public Object[] listAllSubscriptions()
Specified by:
listAllSubscriptions in interface TopicControl

listAllSubscriptionsAsJSON

public String listAllSubscriptionsAsJSON()
                                  throws Exception
Specified by:
listAllSubscriptionsAsJSON in interface TopicControl
Throws:
Exception

listDurableSubscriptions

public Object[] listDurableSubscriptions()
Specified by:
listDurableSubscriptions in interface TopicControl

listDurableSubscriptionsAsJSON

public String listDurableSubscriptionsAsJSON()
                                      throws Exception
Specified by:
listDurableSubscriptionsAsJSON in interface TopicControl
Throws:
Exception

listNonDurableSubscriptions

public Object[] listNonDurableSubscriptions()
Specified by:
listNonDurableSubscriptions in interface TopicControl

listNonDurableSubscriptionsAsJSON

public String listNonDurableSubscriptionsAsJSON()
                                         throws Exception
Specified by:
listNonDurableSubscriptionsAsJSON in interface TopicControl
Throws:
Exception

listMessagesForSubscription

public Map<String,Object>[] listMessagesForSubscription(String queueName)
                                                 throws Exception
Specified by:
listMessagesForSubscription in interface TopicControl
Throws:
Exception

listMessagesForSubscriptionAsJSON

public String listMessagesForSubscriptionAsJSON(String queueName)
                                         throws Exception
Specified by:
listMessagesForSubscriptionAsJSON in interface TopicControl
Throws:
Exception

countMessagesForSubscription

public int countMessagesForSubscription(String clientID,
                                        String subscriptionName,
                                        String filterStr)
                                 throws Exception
Specified by:
countMessagesForSubscription in interface TopicControl
Throws:
Exception

removeMessages

public int removeMessages(String filterStr)
                   throws Exception
Specified by:
removeMessages in interface DestinationControl
Throws:
Exception

dropDurableSubscription

public void dropDurableSubscription(String clientID,
                                    String subscriptionName)
                             throws Exception
Specified by:
dropDurableSubscription in interface TopicControl
Throws:
Exception

dropAllSubscriptions

public void dropAllSubscriptions()
                          throws Exception
Specified by:
dropAllSubscriptions in interface TopicControl
Throws:
Exception

getMBeanInfo

public MBeanInfo getMBeanInfo()
Specified by:
getMBeanInfo in interface DynamicMBean
Overrides:
getMBeanInfo in class StandardMBean


Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.