org.jboss.jms.server.destination
Class QueueService

java.lang.Object
  extended byServiceMBeanSupport
      extended byorg.jboss.jms.server.destination.DestinationServiceSupport
          extended byorg.jboss.jms.server.destination.QueueService
All Implemented Interfaces:
DestinationMBean, QueueMBean, ServerPlugin

public class QueueService
extends DestinationServiceSupport
implements QueueMBean

MBean wrapper around a ManagedQueue

Version:
$Revision: 2746 $ $Id: QueueService.java 2746 2007-05-31 08:07:01Z timfox $
Author:
Ovidiu Feodorov, Tim Fox, Alex Fu
See Also:
Serialized Form

Field Summary
 
Fields inherited from class org.jboss.jms.server.destination.DestinationServiceSupport
destination, dm, idm, ms, nodeId, pm, postOffice, serverPeer, sm, started, tr
 
Constructor Summary
QueueService()
           
QueueService(boolean createdProgrammatically)
           
 
Method Summary
 int getConsumerCount()
           
 int getMessageCount()
           
 MessageCounter getMessageCounter()
           
 MessageStatistics getMessageStatistics()
           
 int getScheduledMessageCount()
           
protected  boolean isQueue()
           
 java.util.List listAllMessages()
           
 java.util.List listAllMessages(java.lang.String selector)
           
 java.util.List listDurableMessages()
           
 java.util.List listDurableMessages(java.lang.String selector)
           
 java.lang.String listMessageCounterAsHTML()
           
 java.lang.String listMessageCounterHistoryAsHTML()
           
 java.util.List listNonDurableMessages()
           
 java.util.List listNonDurableMessages(java.lang.String selector)
           
 void removeAllMessages()
           
 void resetMessageCounter()
           
 void resetMessageCounterHistory()
           
 void startService()
           
 void stopService()
           
 
Methods inherited from class org.jboss.jms.server.destination.DestinationServiceSupport
getDLQ, getDownCacheSize, getExpiryQueue, getFullSize, getInstance, getJNDIName, getMaxSize, getMessageCounterHistoryDayLimit, getName, getPageSize, getRedeliveryDelay, getSecurityConfig, getServerPeer, isClustered, isCreatedProgrammatically, listMessageCounterAsHTML, listMessageCounterHistoryAsHTML, setClustered, setDLQ, setDownCacheSize, setExpiryQueue, setFullSize, setJNDIName, setMaxSize, setMessageCounterHistoryDayLimit, setPageSize, setRedeliveryDelay, setSecurityConfig, setServerPeer, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

QueueService

public QueueService()

QueueService

public QueueService(boolean createdProgrammatically)
Method Detail

startService

public void startService()
                  throws java.lang.Exception
Overrides:
startService in class DestinationServiceSupport
Throws:
java.lang.Exception

stopService

public void stopService()
                 throws java.lang.Exception
Overrides:
stopService in class DestinationServiceSupport
Throws:
java.lang.Exception

getMessageCount

public int getMessageCount()
                    throws java.lang.Exception
Specified by:
getMessageCount in interface QueueMBean
Throws:
java.lang.Exception

getScheduledMessageCount

public int getScheduledMessageCount()
                             throws java.lang.Exception
Specified by:
getScheduledMessageCount in interface QueueMBean
Throws:
java.lang.Exception

getMessageCounter

public MessageCounter getMessageCounter()
Specified by:
getMessageCounter in interface QueueMBean

getMessageStatistics

public MessageStatistics getMessageStatistics()
                                       throws java.lang.Exception
Specified by:
getMessageStatistics in interface QueueMBean
Throws:
java.lang.Exception

listMessageCounterAsHTML

public java.lang.String listMessageCounterAsHTML()
Specified by:
listMessageCounterAsHTML in interface QueueMBean

getConsumerCount

public int getConsumerCount()
                     throws java.lang.Exception
Specified by:
getConsumerCount in interface QueueMBean
Throws:
java.lang.Exception

removeAllMessages

public void removeAllMessages()
                       throws java.lang.Exception
Specified by:
removeAllMessages in interface DestinationMBean
Specified by:
removeAllMessages in class DestinationServiceSupport
Throws:
java.lang.Exception

listAllMessages

public java.util.List listAllMessages()
                               throws java.lang.Exception
Specified by:
listAllMessages in interface QueueMBean
Throws:
java.lang.Exception

listAllMessages

public java.util.List listAllMessages(java.lang.String selector)
                               throws java.lang.Exception
Specified by:
listAllMessages in interface QueueMBean
Throws:
java.lang.Exception

listDurableMessages

public java.util.List listDurableMessages()
                                   throws java.lang.Exception
Specified by:
listDurableMessages in interface QueueMBean
Throws:
java.lang.Exception

listDurableMessages

public java.util.List listDurableMessages(java.lang.String selector)
                                   throws java.lang.Exception
Specified by:
listDurableMessages in interface QueueMBean
Throws:
java.lang.Exception

listNonDurableMessages

public java.util.List listNonDurableMessages()
                                      throws java.lang.Exception
Specified by:
listNonDurableMessages in interface QueueMBean
Throws:
java.lang.Exception

listNonDurableMessages

public java.util.List listNonDurableMessages(java.lang.String selector)
                                      throws java.lang.Exception
Specified by:
listNonDurableMessages in interface QueueMBean
Throws:
java.lang.Exception

resetMessageCounter

public void resetMessageCounter()
Specified by:
resetMessageCounter in interface QueueMBean

listMessageCounterHistoryAsHTML

public java.lang.String listMessageCounterHistoryAsHTML()
Specified by:
listMessageCounterHistoryAsHTML in interface QueueMBean

resetMessageCounterHistory

public void resetMessageCounterHistory()
Specified by:
resetMessageCounterHistory in interface QueueMBean

isQueue

protected boolean isQueue()
Specified by:
isQueue in class DestinationServiceSupport


Copyright © 2006 JBoss Inc. All Rights Reserved.