org.jboss.mq.server.jmx
Class Topic
java.lang.Object
org.jboss.mx.util.JBossNotificationBroadcasterSupport (src)
org.jboss.system.ServiceMBeanSupport (src)
org.jboss.mq.server.jmx.DestinationMBeanSupport (src)
org.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
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()
|
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Topic
public Topic()
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)