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

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: 1.11.4.5 $

Author:

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

Field Summary

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()
int	getDurableMessageCount()
int	getDurableSubscriptionsCount()
MessageCounter[]	getMessageCounter() Get destination message counter array
MessageStatistics[]	getMessageStatistics() Get destination stats array
int	getNonDurableMessageCount()
int	getNonDurableSubscriptionsCount()
String	getTopicName()
protected String	help(List queues)
List	listAllSubscriptions()
List	listDurableMessages(String id, String name)
List	listDurableMessages(String id, String name, String selector)
List	listDurableSubscriptions()
List	listMessages(String id)
List	listMessages(String id, String selector)
List	listNonDurableMessages(String id, String sub)
List	listNonDurableMessages(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

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

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

See Also:

DestinationMBeanSupport.getMessageCounter()

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)