org.jboss.messaging.jms.server.management.jmx.impl
Class ReplicationAwareTopicControlWrapper

java.lang.Object
  extended by javax.management.StandardMBean
      extended by org.jboss.messaging.core.management.jmx.impl.ReplicationAwareStandardMBeanWrapper
          extended by org.jboss.messaging.jms.server.management.jmx.impl.ReplicationAwareTopicControlWrapper
All Implemented Interfaces:
javax.management.DynamicMBean, DestinationControl, TopicControl

public class ReplicationAwareTopicControlWrapper
extends ReplicationAwareStandardMBeanWrapper
implements TopicControl

A ReplicationAwareTopicControlWrapper

Author:
Jeff Mesnil

Constructor Summary
ReplicationAwareTopicControlWrapper(TopicControlImpl localControl, ReplicationOperationInvoker replicationInvoker)
           
 
Method Summary
 int countMessagesForSubscription(java.lang.String clientID, java.lang.String subscriptionName, java.lang.String filterStr)
           
 void dropAllSubscriptions()
           
 void dropDurableSubscription(java.lang.String clientID, java.lang.String subscriptionName)
           
 java.lang.String getAddress()
           
 int getDurableMessageCount()
           
 int getDurableSubscriptionCount()
           
 java.lang.String getJNDIBinding()
           
 javax.management.MBeanInfo getMBeanInfo()
           
 int getMessageCount()
           
 java.lang.String getName()
           
 int getNonDurableMessageCount()
           
 int getNonDurableSubscriptionCount()
           
 int getSubscriptionCount()
           
 boolean isTemporary()
           
 java.lang.Object[] listAllSubscriptions()
           
 java.lang.String listAllSubscriptionsAsJSON()
           
 java.lang.Object[] listDurableSubscriptions()
           
 java.lang.String listDurableSubscriptionsAsJSON()
           
 java.util.Map<java.lang.String,java.lang.Object>[] listMessagesForSubscription(java.lang.String queueName)
           
 java.lang.String listMessagesForSubscriptionAsJSON(java.lang.String queueName)
           
 java.lang.Object[] listNonDurableSubscriptions()
           
 java.lang.String listNonDurableSubscriptionsAsJSON()
           
 int removeMessages(java.lang.String filter)
           
 
Methods inherited from class org.jboss.messaging.core.management.jmx.impl.ReplicationAwareStandardMBeanWrapper
replicationAwareInvoke
 
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, setAttribute, setAttributes, setImplementation
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ReplicationAwareTopicControlWrapper

public ReplicationAwareTopicControlWrapper(TopicControlImpl localControl,
                                           ReplicationOperationInvoker replicationInvoker)
                                    throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

dropAllSubscriptions

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

dropDurableSubscription

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

getDurableMessageCount

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

getDurableSubscriptionCount

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

getNonDurableMessageCount

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

getNonDurableSubscriptionCount

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

getSubscriptionCount

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

listAllSubscriptions

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

listAllSubscriptionsAsJSON

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

listDurableSubscriptions

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

listDurableSubscriptionsAsJSON

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

listMessagesForSubscription

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

listMessagesForSubscriptionAsJSON

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

countMessagesForSubscription

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

listNonDurableSubscriptions

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

listNonDurableSubscriptionsAsJSON

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

getAddress

public java.lang.String getAddress()
Specified by:
getAddress in interface DestinationControl

getJNDIBinding

public java.lang.String getJNDIBinding()
Specified by:
getJNDIBinding in interface DestinationControl

getMessageCount

public int getMessageCount()
                    throws java.lang.Exception
Specified by:
getMessageCount in interface DestinationControl
Throws:
java.lang.Exception

getName

public java.lang.String getName()
Specified by:
getName in interface DestinationControl

isTemporary

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

removeMessages

public int removeMessages(java.lang.String filter)
                   throws java.lang.Exception
Specified by:
removeMessages in interface DestinationControl
Throws:
java.lang.Exception

getMBeanInfo

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


Copyright © 2006 JBoss Inc. All Rights Reserved.