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:
DestinationControl, 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 removeMessages(java.lang.String filterStr)
           
 
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 DestinationControl

isTemporary

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

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()
Specified by:
getMessageCount 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 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

removeMessages

public int removeMessages(java.lang.String filterStr)
                   throws java.lang.Exception
Specified by:
removeMessages in interface DestinationControl
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.