org.jboss.jms.server.destination
Class ManagedQueue

java.lang.Object
  org.jboss.jms.server.destination.ManagedDestination
      org.jboss.jms.server.destination.ManagedQueue

All Implemented Interfaces:

MessagingComponent

public class ManagedQueue
extends ManagedDestination

A ManagedQueue

Version:

$Revision: 2925 $ $Id: ManagedQueue.java 2925 2007-07-25 10:43:58Z timfox $

Author:

Tim Fox, Ovidiu Feodorov, Alex Fu

Field Summary

Fields inherited from class org.jboss.jms.server.destination.ManagedDestination

ALL, clustered, dlq, downCacheSize, DURABLE, expiryQueue, fullSize, jndiName, maxDeliveryAttempts, maxSize, messageCounterHistoryDayLimit, name, NON_DURABLE, pageSize, redeliveryDelay, securityConfig, serverPeer, temporary

Constructor Summary

ManagedQueue()

ManagedQueue(java.lang.String name, int fullSize, int pageSize, int downCacheSize, boolean clustered)

Method Summary

int	getConsumersCount()
int	getDeliveringCount()
int	getMessageCount()
MessageCounter	getMessageCounter()
Queue	getQueue()
int	getScheduledMessageCount()
boolean	isQueue()
java.util.List	listAllMessages(java.lang.String selector)
java.util.List	listDurableMessages(java.lang.String selector)
java.util.List	listNonDurableMessages(java.lang.String selector)
void	removeAllMessages()
void	setMessageCounter(MessageCounter counter)
void	setMessageCounterHistoryDayLimit(int limit)
void	setQueue(Queue queue)
java.lang.String	toString()

Methods inherited from class org.jboss.jms.server.destination.ManagedDestination

getDLQ, getDownCacheSize, getExpiryQueue, getFullSize, getJndiName, getMaxDeliveryAttempts, getMaxSize, getMessageCounterHistoryDayLimit, getName, getPageSize, getRedeliveryDelay, getSecurityConfig, getServerPeer, isClustered, isTemporary, setClustered, setDLQ, setDownCacheSize, setExpiryQueue, setFullSize, setJndiName, setMaxDeliveryAttempts, setMaxSize, setName, setPageSize, setRedeliveryDelay, setSecurityConfig, setServerPeer, setTemporary, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ManagedQueue

public ManagedQueue()

ManagedQueue

public ManagedQueue(java.lang.String name,
                    int fullSize,
                    int pageSize,
                    int downCacheSize,
                    boolean clustered)

Method Detail

isQueue

public boolean isQueue()

Specified by:

isQueue in class ManagedDestination

setMessageCounterHistoryDayLimit

public void setMessageCounterHistoryDayLimit(int limit)
                                      throws java.lang.Exception

Overrides:

setMessageCounterHistoryDayLimit in class ManagedDestination

Throws:

java.lang.Exception

getMessageCount

public int getMessageCount()
                    throws java.lang.Exception

Throws:

java.lang.Exception

getDeliveringCount

public int getDeliveringCount()
                       throws java.lang.Exception

Throws:

java.lang.Exception

getScheduledMessageCount

public int getScheduledMessageCount()
                             throws java.lang.Exception

Throws:

java.lang.Exception

getConsumersCount

public int getConsumersCount()
                      throws java.lang.Exception

Throws:

java.lang.Exception

removeAllMessages

public void removeAllMessages()
                       throws java.lang.Throwable

Throws:

java.lang.Throwable

listAllMessages

public java.util.List listAllMessages(java.lang.String selector)
                               throws java.lang.Exception

Throws:

java.lang.Exception

listDurableMessages

public java.util.List listDurableMessages(java.lang.String selector)
                                   throws java.lang.Exception

Throws:

java.lang.Exception

listNonDurableMessages

public java.util.List listNonDurableMessages(java.lang.String selector)
                                      throws java.lang.Exception

Throws:

java.lang.Exception

getMessageCounter

public MessageCounter getMessageCounter()

setMessageCounter

public void setMessageCounter(MessageCounter counter)

setQueue

public void setQueue(Queue queue)

getQueue

public Queue getQueue()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object