org.jboss.mq.server.jmx
Class Queue

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.Queue
All Implemented Interfaces:
DestinationMBean (src) , MBeanRegistration (src) , NotificationBroadcaster (src) , NotificationEmitter (src) , Service (src) , ServiceMBean (src)

public class Queue
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
Queue()
           
 
Method Summary
 MessageCounter (src) [] getMessageCounter()
          Get destination message counter array
 MessageStatistics (src) [] getMessageStatistics()
          Get destination stats array
 int getQueueDepth()
          Gets the QueueDepth attribute of the BasicQueue object
 java.lang.String getQueueName()
           
 int getReceiversCount()
           
 int getScheduledMessageCount()
          Gets the ScheduledMessageCount attribute of the BasicQueue object
 java.util.List listMessages()
           
 java.util.List listMessages(java.lang.String selector)
           
 java.util.List listReceivers()
           
 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

Queue

public Queue()
Method Detail

getQueueName

public java.lang.String getQueueName()

getQueueDepth

public int getQueueDepth()
                  throws java.lang.Exception
Gets the QueueDepth attribute of the BasicQueue object

Returns:
The QueueDepth value
Throws:
java.lang.Exception - Description of Exception

getScheduledMessageCount

public int getScheduledMessageCount()
                             throws java.lang.Exception
Gets the ScheduledMessageCount attribute of the BasicQueue object

Returns:
The ScheduledMessageCount value
Throws:
java.lang.Exception - Description of Exception

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()

getReceiversCount

public int getReceiversCount()

listReceivers

public java.util.List listReceivers()

listMessages

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

listMessages

public java.util.List listMessages(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