org.jboss.mq.server.jmx
Class Topic

java.lang.Object
  org.jboss.mx.util.JBossNotificationBroadcasterSupport
      org.jboss.system.ServiceMBeanSupport
          org.jboss.mq.server.jmx.DestinationMBeanSupport
              org.jboss.mq.server.jmx.Topic

All Implemented Interfaces:

javax.management.MBeanRegistration, javax.management.NotificationBroadcaster, javax.management.NotificationEmitter, DestinationMBean, TopicMBean, org.jboss.system.Service, org.jboss.system.ServiceMBean

Direct Known Subclasses:

Topic

public class Topic
extends DestinationMBeanSupport
implements TopicMBean

This class is a message queue which is stored (hashed by Destination) on the JMS provider

Version:

$Revision: 57198 $

Author:

Norbert Lataille (Norbert.Lataille@m4x.org), Hiram Chirino, Peter Antman

Field Summary

protected JMSTopic

destination

Fields inherited from class org.jboss.mq.server.jmx.DestinationMBeanSupport

destinationName, jbossMQService, jndiBound, jndiName, parameters, securityConf, securityManager, spyDest

Fields inherited from class org.jboss.system.ServiceMBeanSupport

log, server, SERVICE_CONTROLLER_SIG, serviceName

Fields inherited from interface org.jboss.system.ServiceMBean

CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED

Constructor Summary

Topic()

Method Summary

protected BasicQueue	findBasicQueue(String id)
protected BasicQueue	findDurableBasicQueue(String id, String name)
protected BasicQueue	findNonDurableBasicQueue(String id, String sub)
int	getAllMessageCount()
int	getAllSubscriptionsCount()
long	getDurableInProcessMessageCount(String id, String name)
int	getDurableMessageCount()
long	getDurableMessageCount(String id, String name)
long	getDurableScheduledMessageCount(String id, String name)
int	getDurableSubscriptionsCount()
MessageCounter[]	getMessageCounter() Get destination message counter array
MessageStatistics[]	getMessageStatistics() Get destination stats array
long	getNonDurableInProcessMessageCount(String id, String sub)
int	getNonDurableMessageCount()
long	getNonDurableMessageCount(String id, String sub)
long	getNonDurableScheduledMessageCount(String id, String sub)
int	getNonDurableSubscriptionsCount()
String	getTopicName()
protected String	help(List queues)
List	listAllSubscriptions()
List	listDurableInProcessMessages(String id, String name)
List	listDurableInProcessMessages(String id, String name, String selector)
List	listDurableMessages(String id, String name)
List	listDurableMessages(String id, String name, String selector)
List	listDurableScheduledMessages(String id, String name)
List	listDurableScheduledMessages(String id, String name, String selector)
List	listDurableSubscriptions()
List	listMessages(String id)
List	listMessages(String id, String selector)
List	listNonDurableInProcessMessages(String id, String sub)
List	listNonDurableInProcessMessages(String id, String sub, String selector)
List	listNonDurableMessages(String id, String sub)
List	listNonDurableMessages(String id, String sub, String selector)
List	listNonDurableScheduledMessages(String id, String sub)
List	listNonDurableScheduledMessages(String id, String sub, String selector)
List	listNonDurableSubscriptions()
void	removeAllMessages() Get the value of JBossMQService.
void	startService()
void	stopService()

Methods inherited from class org.jboss.mq.server.jmx.DestinationMBeanSupport

createService, getDestinationManager, getExpiryDestination, getInitialContext, getInMemory, getJNDIName, getMaxDepth, getMessageCounterHistoryDayLimit, getObjectName, getReceiversImpl, getRecoveryRetries, getRedeliveryDelay, getRedeliveryLimit, getSecurityConf, getSecurityManager, getSpyDest, listMessageCounter, listMessageCounterHistory, resetMessageCounter, resetMessageCounterHistory, setDestinationManager, setExpiryDestination, setInMemory, setJNDIName, setMaxDepth, setMessageCounterHistoryDayLimit, setReceiversImpl, setRecoveryRetries, setRedeliveryDelay, setRedeliveryLimit, setSecurityConf, setSecurityManager, setupExpiryDestination, setupSecurityManager, teardownSecurityManager

Methods inherited from class org.jboss.system.ServiceMBeanSupport

create, destroy, destroyService, getDeploymentInfo, getLog, getName, getNextNotificationSequenceNumber, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, postDeregister, postRegister, preDeregister, preRegister, start, stop

Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, handleNotification, nextNotificationSequenceNumber, removeNotificationListener, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.jboss.mq.server.jmx.DestinationMBean

getDestinationManager, getExpiryDestination, getInMemory, getJNDIName, getMaxDepth, getMessageCounterHistoryDayLimit, getReceiversImpl, getRecoveryRetries, getRedeliveryDelay, getRedeliveryLimit, listMessageCounter, listMessageCounterHistory, resetMessageCounter, resetMessageCounterHistory, setDestinationManager, setExpiryDestination, setInMemory, setJNDIName, setMaxDepth, setMessageCounterHistoryDayLimit, setReceiversImpl, setRecoveryRetries, setRedeliveryDelay, setRedeliveryLimit, setSecurityConf, setSecurityManager

Methods inherited from interface org.jboss.system.ServiceMBean

getName, getState, getStateString, jbossInternalLifecycle

Methods inherited from interface org.jboss.system.Service

create, destroy, start, stop

Methods inherited from interface javax.management.MBeanRegistration

postDeregister, postRegister, preDeregister, preRegister

Field Detail

destination

protected JMSTopic destination

Constructor Detail

Topic

public Topic()

Method Detail

getTopicName

public String getTopicName()

Specified by:

getTopicName in interface TopicMBean

startService

public void startService()
                  throws Exception

Overrides:

startService in class DestinationMBeanSupport

Throws:

Exception

stopService

public void stopService()
                 throws Exception

Overrides:

stopService in class DestinationMBeanSupport

Throws:

Exception

removeAllMessages

public void removeAllMessages()
                       throws Exception

Description copied from interface: DestinationMBean

Get the value of JBossMQService.

Specified by:

removeAllMessages in interface DestinationMBean

Throws:

Exception

See Also:

DestinationMBean.removeAllMessages()

getAllMessageCount

public int getAllMessageCount()

Specified by:

getAllMessageCount in interface TopicMBean

getDurableMessageCount

public int getDurableMessageCount()

Specified by:

getDurableMessageCount in interface TopicMBean

getNonDurableMessageCount

public int getNonDurableMessageCount()

Specified by:

getNonDurableMessageCount in interface TopicMBean

getAllSubscriptionsCount

public int getAllSubscriptionsCount()

Specified by:

getAllSubscriptionsCount in interface TopicMBean

getDurableSubscriptionsCount

public int getDurableSubscriptionsCount()

Specified by:

getDurableSubscriptionsCount in interface TopicMBean

getNonDurableSubscriptionsCount

public int getNonDurableSubscriptionsCount()

Specified by:

getNonDurableSubscriptionsCount in interface TopicMBean

listAllSubscriptions

public List listAllSubscriptions()

Specified by:

listAllSubscriptions in interface TopicMBean

listDurableSubscriptions

public List listDurableSubscriptions()

Specified by:

listDurableSubscriptions in interface TopicMBean

listNonDurableSubscriptions

public List listNonDurableSubscriptions()

Specified by:

listNonDurableSubscriptions in interface TopicMBean

listMessages

public List listMessages(String id)
                  throws Exception

Specified by:

listMessages in interface TopicMBean

Throws:

Exception

listMessages

public List listMessages(String id,
                         String selector)
                  throws Exception

Specified by:

listMessages in interface TopicMBean

Throws:

Exception

listNonDurableMessages

public List listNonDurableMessages(String id,
                                   String sub)
                            throws Exception

Specified by:

listNonDurableMessages in interface TopicMBean

Throws:

Exception

listNonDurableMessages

public List listNonDurableMessages(String id,
                                   String sub,
                                   String selector)
                            throws Exception

Specified by:

listNonDurableMessages in interface TopicMBean

Throws:

Exception

listDurableMessages

public List listDurableMessages(String id,
                                String name)
                         throws Exception

Specified by:

listDurableMessages in interface TopicMBean

Throws:

Exception

listDurableMessages

public List listDurableMessages(String id,
                                String name,
                                String selector)
                         throws Exception

Specified by:

listDurableMessages in interface TopicMBean

Throws:

Exception

getNonDurableMessageCount

public long getNonDurableMessageCount(String id,
                                      String sub)
                               throws Exception

Specified by:

getNonDurableMessageCount in interface TopicMBean

Throws:

Exception

getDurableMessageCount

public long getDurableMessageCount(String id,
                                   String name)
                            throws Exception

Specified by:

getDurableMessageCount in interface TopicMBean

Throws:

Exception

listNonDurableScheduledMessages

public List listNonDurableScheduledMessages(String id,
                                            String sub)
                                     throws Exception

Specified by:

listNonDurableScheduledMessages in interface TopicMBean

Throws:

Exception

listNonDurableScheduledMessages

public List listNonDurableScheduledMessages(String id,
                                            String sub,
                                            String selector)
                                     throws Exception

Specified by:

listNonDurableScheduledMessages in interface TopicMBean

Throws:

Exception

listDurableScheduledMessages

public List listDurableScheduledMessages(String id,
                                         String name)
                                  throws Exception

Specified by:

listDurableScheduledMessages in interface TopicMBean

Throws:

Exception

listDurableScheduledMessages

public List listDurableScheduledMessages(String id,
                                         String name,
                                         String selector)
                                  throws Exception

Specified by:

listDurableScheduledMessages in interface TopicMBean

Throws:

Exception

getNonDurableScheduledMessageCount

public long getNonDurableScheduledMessageCount(String id,
                                               String sub)
                                        throws Exception

Specified by:

getNonDurableScheduledMessageCount in interface TopicMBean

Throws:

Exception

getDurableScheduledMessageCount

public long getDurableScheduledMessageCount(String id,
                                            String name)
                                     throws Exception

Specified by:

getDurableScheduledMessageCount in interface TopicMBean

Throws:

Exception

listNonDurableInProcessMessages

public List listNonDurableInProcessMessages(String id,
                                            String sub)
                                     throws Exception

Specified by:

listNonDurableInProcessMessages in interface TopicMBean

Throws:

Exception

listNonDurableInProcessMessages

public List listNonDurableInProcessMessages(String id,
                                            String sub,
                                            String selector)
                                     throws Exception

Specified by:

listNonDurableInProcessMessages in interface TopicMBean

Throws:

Exception

listDurableInProcessMessages

public List listDurableInProcessMessages(String id,
                                         String name)
                                  throws Exception

Specified by:

listDurableInProcessMessages in interface TopicMBean

Throws:

Exception

listDurableInProcessMessages

public List listDurableInProcessMessages(String id,
                                         String name,
                                         String selector)
                                  throws Exception

Specified by:

listDurableInProcessMessages in interface TopicMBean

Throws:

Exception

getNonDurableInProcessMessageCount

public long getNonDurableInProcessMessageCount(String id,
                                               String sub)
                                        throws Exception

Specified by:

getNonDurableInProcessMessageCount in interface TopicMBean

Throws:

Exception

getDurableInProcessMessageCount

public long getDurableInProcessMessageCount(String id,
                                            String name)
                                     throws Exception

Specified by:

getDurableInProcessMessageCount in interface TopicMBean

Throws:

Exception

getMessageCounter

public MessageCounter[] getMessageCounter()

Description copied from class: DestinationMBeanSupport

Get destination message counter array

Specified by:

getMessageCounter in interface DestinationMBean

Specified by:

getMessageCounter in class DestinationMBeanSupport

Returns:

MessageCounter[]

getMessageStatistics

public MessageStatistics[] getMessageStatistics()
                                         throws Exception

Description copied from class: DestinationMBeanSupport

Get destination stats array

Specified by:

getMessageStatistics in interface DestinationMBean

Specified by:

getMessageStatistics in class DestinationMBeanSupport

Returns:

MessageStatistics[]

Throws:

Exception - for any error

findBasicQueue

protected BasicQueue findBasicQueue(String id)
                             throws Exception

Throws:

Exception

findNonDurableBasicQueue

protected BasicQueue findNonDurableBasicQueue(String id,
                                              String sub)
                                       throws Exception

Throws:

Exception

findDurableBasicQueue

protected BasicQueue findDurableBasicQueue(String id,
                                           String name)
                                    throws Exception

Throws:

Exception

help

protected String help(List queues)