org.jboss.mq.server.jmx
Class Topic

java.lang.Object
  extended byorg.jboss.mx.util.JBossNotificationBroadcasterSupport (src) 
      extended byorg.jboss.system.ServiceMBeanSupport (src) 
          extended byorg.jboss.mq.server.jmx.DestinationMBeanSupport (src) 
              extended byorg.jboss.mq.server.jmx.Topic
All Implemented Interfaces:
DestinationMBean (src) , MBeanRegistration (src) , NotificationBroadcaster (src) , NotificationEmitter (src) , Service (src) , ServiceMBean (src)

public class Topic
extends DestinationMBeanSupport (src)

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


Field Summary
 
Fields inherited from class org.jboss.system.ServiceMBeanSupport (src)
log, server, SERVICE_CONTROLLER_SIG, serviceName
 
Fields inherited from interface org.jboss.system.ServiceMBean (src)
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 (src) findBasicQueue(java.lang.String id)
           
 int getAllMessageCount()
           
 int getAllSubscriptionsCount()
           
 int getDurableMessageCount()
           
 int getDurableSubscriptionsCount()
           
 MessageCounter (src) [] getMessageCounter()
          Get destination message counter array
 MessageStatistics (src) [] getMessageStatistics()
          Get destination stats array
 int getNonDurableMessageCount()
           
 int getNonDurableSubscriptionsCount()
           
 java.lang.String getTopicName()
           
protected  java.lang.String help(java.util.List queues)
           
 java.util.List listAllSubscriptions()
           
 java.util.List listDurableSubscriptions()
           
 java.util.List listMessages(java.lang.String id)
           
 java.util.List listMessages(java.lang.String id, java.lang.String selector)
           
 java.util.List listNonDurableSubscriptions()
           
 void removeAllMessages()
          Get the value of JBossMQService.
 void startService()
          Sub-classes should override this method to provide custum 'start' logic.
 
Methods inherited from class org.jboss.mq.server.jmx.DestinationMBeanSupport (src)
createService, getDestinationManager, getInMemory, getJNDIName, getMaxDepth, getMessageCounterHistoryDayLimit, getObjectName, getReceiversImpl, getRedeliveryDelay, getRedeliveryLimit, getSecurityConf, getSecurityManager, getSpyDest, listMessageCounter, listMessageCounterHistory, resetMessageCounter, resetMessageCounterHistory, setDestinationManager, setInMemory, setJNDIName, setMaxDepth, setMessageCounterHistoryDayLimit, setReceiversImpl, setRedeliveryDelay, setRedeliveryLimit, setSecurityConf, setSecurityManager, stopService
 
Methods inherited from class org.jboss.system.ServiceMBeanSupport (src)
create, destroy, destroyService, 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 (src)
addNotificationListener, getNotificationInfo, handleNotification, 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.system.ServiceMBean (src)
getName, getState, getStateString, jbossInternalLifecycle
 
Methods inherited from interface org.jboss.system.Service (src)
create, destroy, start, stop
 
Methods inherited from interface javax.management.MBeanRegistration (src)
postDeregister, postRegister, preDeregister, preRegister
 

Constructor Detail

Topic

public Topic()
Method Detail

getTopicName

public java.lang.String getTopicName()

startService

public void startService()
                  throws java.lang.Exception
Description copied from class: ServiceMBeanSupport (src)
Sub-classes should override this method to provide custum 'start' logic.

This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.

Overrides:
startService in class DestinationMBeanSupport (src)
Throws:
java.lang.Exception

removeAllMessages

public void removeAllMessages()
                       throws java.lang.Exception
Description copied from interface: DestinationMBean (src)
Get the value of JBossMQService.

Returns:
value of JBossMQService.
Throws:
java.lang.Exception
See Also:
DestinationMBean.removeAllMessages()

getAllMessageCount

public int getAllMessageCount()

getDurableMessageCount

public int getDurableMessageCount()

getNonDurableMessageCount

public int getNonDurableMessageCount()

getAllSubscriptionsCount

public int getAllSubscriptionsCount()

getDurableSubscriptionsCount

public int getDurableSubscriptionsCount()

getNonDurableSubscriptionsCount

public int getNonDurableSubscriptionsCount()

listAllSubscriptions

public java.util.List listAllSubscriptions()

listDurableSubscriptions

public java.util.List listDurableSubscriptions()

listNonDurableSubscriptions

public java.util.List listNonDurableSubscriptions()

listMessages

public java.util.List listMessages(java.lang.String id)
                            throws java.lang.Exception
Throws:
java.lang.Exception

listMessages

public java.util.List listMessages(java.lang.String id,
                                   java.lang.String selector)
                            throws java.lang.Exception
Throws:
java.lang.Exception

getMessageCounter

public MessageCounter (src) [] getMessageCounter()
Description copied from class: DestinationMBeanSupport (src)
Get destination message counter array

Specified by:
getMessageCounter in interface DestinationMBean (src)
Specified by:
getMessageCounter in class DestinationMBeanSupport (src)
Returns:
MessageCounter[]
See Also:
DestinationMBeanSupport.getMessageCounter()

getMessageStatistics

public MessageStatistics (src) [] getMessageStatistics()
                                         throws java.lang.Exception
Description copied from class: DestinationMBeanSupport (src)
Get destination stats array

Specified by:
getMessageStatistics in interface DestinationMBean (src)
Specified by:
getMessageStatistics in class DestinationMBeanSupport (src)
Returns:
MessageStatistics[]
Throws:
java.lang.Exception - for any error

findBasicQueue

protected BasicQueue (src)  findBasicQueue(java.lang.String id)
                             throws java.lang.Exception
Throws:
java.lang.Exception

help

protected java.lang.String help(java.util.List queues)