org.jboss.messaging.jms.server.management.impl
Class TopicControlImpl

java.lang.Object
  extended by org.jboss.messaging.jms.server.management.impl.TopicControlImpl
All Implemented Interfaces:
DestinationControlMBean, TopicControl

public class TopicControlImpl
extends java.lang.Object
implements TopicControl

Version:
$Revision$
Author:
Jeff Mesnil

Constructor Summary
TopicControlImpl(JBossTopic topic, AddressControl addressControl, java.lang.String jndiBinding, ManagementService managementService)
           
 
Method Summary
 int countMessagesForSubscription(java.lang.String clientID, java.lang.String subscriptionName, java.lang.String filterStr)
           
static java.lang.String createFilterFromJMSSelector(java.lang.String selectorStr)
           
 void dropAllSubscriptions()
           
 void dropDurableSubscription(java.lang.String clientID, java.lang.String subscriptionName)
           
 java.lang.String getAddress()
           
 int getDurableMessageCount()
           
 int getDurableSubscriptionCount()
           
 java.lang.String getJNDIBinding()
           
 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 removeAllMessages()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TopicControlImpl

public TopicControlImpl(JBossTopic topic,
                        AddressControl addressControl,
                        java.lang.String jndiBinding,
                        ManagementService managementService)
Method Detail

createFilterFromJMSSelector

public static java.lang.String createFilterFromJMSSelector(java.lang.String selectorStr)
                                                    throws MessagingException
Throws:
MessagingException

getName

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

isTemporary

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

getAddress

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

getJNDIBinding

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

getMessageCount

public int getMessageCount()
Specified by:
getMessageCount in interface DestinationControlMBean

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 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

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

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

removeAllMessages

public int removeAllMessages()
                      throws java.lang.Exception
Specified by:
removeAllMessages in interface DestinationControlMBean
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

dropAllSubscriptions

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


Copyright © 2006 JBoss Inc. All Rights Reserved.