org.hornetq.jms.management.impl

Class JMSTopicControlImpl

java.lang.Object

javax.management.StandardMBean

org.hornetq.jms.management.impl.JMSTopicControlImpl

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, DestinationControl, TopicControl

public class JMSTopicControlImpl
extends StandardMBean
implements TopicControl

Version:

$Revision$

Author:

Jeff Mesnil

Constructor Summary

Constructors

Constructor and Description
JMSTopicControlImpl(HornetQDestination topic, JMSServerManager jmsServerManager, AddressControl addressControl, ManagementService managementService)

Method Summary

Methods

Modifier and Type	Method and Description
void	addJNDI(String jndi) Add the JNDI binding to this destination
int	countMessagesForSubscription(String clientID, String subscriptionName, String filterStr) Counts the number of messages in the subscription specified by the specified client ID and subscription name.
static String	createFilterFromJMSSelector(String selectorStr)
void	dropAllSubscriptions() Drops all subscriptions.
void	dropDurableSubscription(String clientID, String subscriptionName) Drops the subscription specified by the specified client ID and subscription name.
String	getAddress() Returns the HornetQ address corresponding to this destination.
int	getDeliveringCount() Returns the number of messages that this queue is currently delivering to its consumers.
int	getDurableMessageCount() Returns the number of messages for all durable subscribers for this topic.
int	getDurableSubscriptionCount() Returns the number of durable subscribers for this topic.
String[]	getJNDIBindings() Returns the JNDI bindings associated to this connection factory.
MBeanInfo	getMBeanInfo()
long	getMessageCount() Returns the number of messages currently in this destination.
long	getMessagesAdded() Returns the number of messages added to this queue since it was created.
String	getName() Returns the name of this destination.
int	getNonDurableMessageCount() Returns the number of messages for all non-durable subscribers for this topic.
int	getNonDurableSubscriptionCount() Returns the number of non-durable subscribers for this topic.
int	getSubscriptionCount() Returns the number of (durable and non-durable) subscribers for this topic.
boolean	isTemporary() Returns whether this destination is temporary.
Object[]	listAllSubscriptions() Lists all the subscriptions for this topic (both durable and non-durable).
String	listAllSubscriptionsAsJSON() Lists all the subscriptions for this topic (both durable and non-durable) using JSON serialization.
Object[]	listDurableSubscriptions() Lists all the durable subscriptions for this topic.
String	listDurableSubscriptionsAsJSON() Lists all the durable subscriptions using JSON serialization.
Map<String,Object>[]	listMessagesForSubscription(String queueName) Lists all the messages in this queue matching the specified queue representing the subscription.
String	listMessagesForSubscriptionAsJSON(String queueName) Lists all the messages in this queue matching the specified queue representing the subscription using JSON serialization.
Object[]	listNonDurableSubscriptions() Lists all the non-durable subscriptions for this topic.
String	listNonDurableSubscriptionsAsJSON() Lists all the non-durable subscriptions using JSON serialization.
void	removeJNDI(String jndi)
int	removeMessages(String filterStr) Removed all the messages which matches the specified JMS filter from this destination.

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

Description copied from interface: TopicControl

Add the JNDI binding to this destination

Specified by:

addJNDI in interface TopicControl

Throws:

Exception

removeJNDI

public void removeJNDI(String jndi)
                throws Exception

Specified by:

removeJNDI in interface TopicControl

Throws:

Exception

getJNDIBindings

public String[] getJNDIBindings()

Description copied from interface: TopicControl

Returns the JNDI bindings associated to this connection factory.

Specified by:

getJNDIBindings in interface TopicControl

getName

public String getName()

Description copied from interface: DestinationControl

Returns the name of this destination.

Specified by:

getName in interface DestinationControl

isTemporary

public boolean isTemporary()

Description copied from interface: DestinationControl

Returns whether this destination is temporary.

Specified by:

isTemporary in interface DestinationControl

getAddress

public String getAddress()

Description copied from interface: DestinationControl

Returns the HornetQ address corresponding to this destination.

Specified by:

getAddress in interface DestinationControl

getMessageCount

public long getMessageCount()

Description copied from interface: DestinationControl

Returns the number of messages currently in this destination.

Specified by:

getMessageCount in interface DestinationControl

getDeliveringCount

public int getDeliveringCount()

Description copied from interface: DestinationControl

Returns the number of messages that this queue is currently delivering to its consumers.

Specified by:

getDeliveringCount in interface DestinationControl

getMessagesAdded

public long getMessagesAdded()

Description copied from interface: DestinationControl

Returns the number of messages added to this queue since it was created.

Specified by:

getMessagesAdded in interface DestinationControl

getDurableMessageCount

public int getDurableMessageCount()

Description copied from interface: TopicControl

Returns the number of messages for all durable subscribers for this topic.

Specified by:

getDurableMessageCount in interface TopicControl

getNonDurableMessageCount

public int getNonDurableMessageCount()

Description copied from interface: TopicControl

Returns the number of messages for all non-durable subscribers for this topic.

Specified by:

getNonDurableMessageCount in interface TopicControl

getSubscriptionCount

public int getSubscriptionCount()

Description copied from interface: TopicControl

Returns the number of (durable and non-durable) subscribers for this topic.

Specified by:

getSubscriptionCount in interface TopicControl

getDurableSubscriptionCount

public int getDurableSubscriptionCount()

Description copied from interface: TopicControl

Returns the number of durable subscribers for this topic.

Specified by:

getDurableSubscriptionCount in interface TopicControl

getNonDurableSubscriptionCount

public int getNonDurableSubscriptionCount()

Description copied from interface: TopicControl

Returns the number of non-durable subscribers for this topic.

Specified by:

getNonDurableSubscriptionCount in interface TopicControl

listAllSubscriptions

public Object[] listAllSubscriptions()

Description copied from interface: TopicControl

Lists all the subscriptions for this topic (both durable and non-durable).

Specified by:

listAllSubscriptions in interface TopicControl

listAllSubscriptionsAsJSON

public String listAllSubscriptionsAsJSON()
                                  throws Exception

Description copied from interface: TopicControl

Lists all the subscriptions for this topic (both durable and non-durable) using JSON serialization.
Java objects can be recreated from JSON serialization using SubscriptionInfo.from(String).

Specified by:

listAllSubscriptionsAsJSON in interface TopicControl

Throws:

Exception

listDurableSubscriptions

public Object[] listDurableSubscriptions()

Description copied from interface: TopicControl

Lists all the durable subscriptions for this topic.

Specified by:

listDurableSubscriptions in interface TopicControl

listDurableSubscriptionsAsJSON

public String listDurableSubscriptionsAsJSON()
                                      throws Exception

Description copied from interface: TopicControl

Lists all the durable subscriptions using JSON serialization.
Java objects can be recreated from JSON serialization using SubscriptionInfo.from(String).

Specified by:

listDurableSubscriptionsAsJSON in interface TopicControl

Throws:

Exception

listNonDurableSubscriptions

public Object[] listNonDurableSubscriptions()

Description copied from interface: TopicControl

Lists all the non-durable subscriptions for this topic.

Specified by:

listNonDurableSubscriptions in interface TopicControl

listNonDurableSubscriptionsAsJSON

public String listNonDurableSubscriptionsAsJSON()
                                         throws Exception

Description copied from interface: TopicControl

Lists all the non-durable subscriptions using JSON serialization.
Java objects can be recreated from JSON serialization using SubscriptionInfo.from(String).

Specified by:

listNonDurableSubscriptionsAsJSON in interface TopicControl

Throws:

Exception

listMessagesForSubscription

public Map<String,Object>[] listMessagesForSubscription(String queueName)
                                                 throws Exception

Description copied from interface: TopicControl

Lists all the messages in this queue matching the specified queue representing the subscription.
1 Map represents 1 message, keys are the message's properties and headers, values are the corresponding values.

Specified by:

listMessagesForSubscription in interface TopicControl

Throws:

Exception

listMessagesForSubscriptionAsJSON

public String listMessagesForSubscriptionAsJSON(String queueName)
                                         throws Exception

Description copied from interface: TopicControl

Lists all the messages in this queue matching the specified queue representing the subscription using JSON serialization.

Specified by:

listMessagesForSubscriptionAsJSON in interface TopicControl

Throws:

Exception

countMessagesForSubscription

public int countMessagesForSubscription(String clientID,
                               String subscriptionName,
                               String filterStr)
                                 throws Exception

Description copied from interface: TopicControl

Counts the number of messages in the subscription specified by the specified client ID and subscription name. Only messages matching the filter will be counted.
Using null or an empty filter will count all messages from this queue.

Specified by:

countMessagesForSubscription in interface TopicControl

Throws:

Exception

removeMessages

public int removeMessages(String filterStr)
                   throws Exception

Description copied from interface: DestinationControl

Removed all the messages which matches the specified JMS filter from this destination.
Using null or an empty filter will remove all messages from this destination.

Specified by:

removeMessages in interface DestinationControl

Returns:

the number of removed messages

Throws:

Exception

dropDurableSubscription

public void dropDurableSubscription(String clientID,
                           String subscriptionName)
                             throws Exception

Description copied from interface: TopicControl

Drops the subscription specified by the specified client ID and subscription name.

Specified by:

dropDurableSubscription in interface TopicControl

Throws:

Exception

dropAllSubscriptions

public void dropAllSubscriptions()
                          throws Exception

Description copied from interface: TopicControl

Drops all subscriptions.

Specified by:

dropAllSubscriptions in interface TopicControl

Throws:

Exception

getMBeanInfo

public MBeanInfo getMBeanInfo()

Specified by:

getMBeanInfo in interface DynamicMBean

Overrides:

getMBeanInfo in class StandardMBean