org.jboss.jms.server.destination
Class ManagedTopic

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

All Implemented Interfaces:

MessagingComponent

public class ManagedTopic
extends ManagedDestination

A ManagedTopic

Version:

$Revision: 2984 $ $Id: ManagedTopic.java 2984 2007-08-08 20:44:03Z 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

ManagedTopic()

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

Method Summary

int	getAllMessageCount()
int	getAllSubscriptionsCount()
int	getDurableMessageCount()
int	getDurableSubscriptionsCount()
java.util.List	getMessageCounters()
int	getNonDurableMessageCount()
int	getNonDurableSubscriptionsCount()
boolean	isQueue()
java.util.List	listAllMessages(java.lang.String subId, java.lang.String selector)
java.util.List	listAllSubscriptions()
java.lang.String	listAllSubscriptionsAsHTML()
java.util.List	listDurableMessages(java.lang.String subId, java.lang.String selector)
java.util.List	listDurableSubscriptions()
java.lang.String	listDurableSubscriptionsAsHTML()
java.util.List	listNonDurableMessages(java.lang.String subId, java.lang.String selector)
java.util.List	listNonDurableSubscriptions()
java.lang.String	listNonDurableSubscriptionsAsHTML()
void	removeAllMessages()
void	setMessageCounterHistoryDayLimit(int limit)

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, toString, wait, wait, wait

Constructor Detail

ManagedTopic

public ManagedTopic()

ManagedTopic

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

Method Detail

removeAllMessages

public void removeAllMessages()
                       throws java.lang.Throwable

Throws:

java.lang.Throwable

getAllMessageCount

public int getAllMessageCount()
                       throws java.lang.Exception

Throws:

java.lang.Exception

getDurableMessageCount

public int getDurableMessageCount()
                           throws java.lang.Exception

Throws:

java.lang.Exception

getNonDurableMessageCount

public int getNonDurableMessageCount()
                              throws java.lang.Exception

Throws:

java.lang.Exception

getAllSubscriptionsCount

public int getAllSubscriptionsCount()
                             throws java.lang.Exception

Throws:

java.lang.Exception

getDurableSubscriptionsCount

public int getDurableSubscriptionsCount()
                                 throws java.lang.Exception

Throws:

java.lang.Exception

getNonDurableSubscriptionsCount

public int getNonDurableSubscriptionsCount()
                                    throws java.lang.Exception

Throws:

java.lang.Exception

listAllSubscriptions

public java.util.List listAllSubscriptions()
                                    throws java.lang.Exception

Throws:

java.lang.Exception

listDurableSubscriptions

public java.util.List listDurableSubscriptions()
                                        throws java.lang.Exception

Throws:

java.lang.Exception

listNonDurableSubscriptions

public java.util.List listNonDurableSubscriptions()
                                           throws java.lang.Exception

Throws:

java.lang.Exception

listAllSubscriptionsAsHTML

public java.lang.String listAllSubscriptionsAsHTML()
                                            throws java.lang.Exception

Throws:

java.lang.Exception

listDurableSubscriptionsAsHTML

public java.lang.String listDurableSubscriptionsAsHTML()
                                                throws java.lang.Exception

Throws:

java.lang.Exception

listNonDurableSubscriptionsAsHTML

public java.lang.String listNonDurableSubscriptionsAsHTML()
                                                   throws java.lang.Exception

Throws:

java.lang.Exception

listAllMessages

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

Throws:

java.lang.Exception

listDurableMessages

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

Throws:

java.lang.Exception

listNonDurableMessages

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

Throws:

java.lang.Exception

getMessageCounters

public java.util.List getMessageCounters()
                                  throws java.lang.Exception

Throws:

java.lang.Exception

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