org.jboss.jms.server.destination
Class TopicService

java.lang.Object
  ServiceMBeanSupport
      org.jboss.jms.server.destination.DestinationServiceSupport
          org.jboss.jms.server.destination.TopicService

All Implemented Interfaces:

DestinationMBean, TopicMBean

public class TopicService
extends DestinationServiceSupport
implements TopicMBean

A deployable JBoss Messaging topic.

Version:

$Revision: 2868 $ $Id: TopicService.java 2868 2007-07-10 20:22:16Z timfox $

Author:

Ovidiu Feodorov, Tim Fox, Alex Fu, Juha Lindfors

Field Summary

static java.lang.String

SUBSCRIPTION_MESSAGECOUNTER_PREFIX

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

destination, nodeId, serverPeer, started

Constructor Summary

TopicService()

TopicService(boolean createdProgrammatically)

Method Summary

int	getAllMessageCount()
int	getAllSubscriptionsCount() All subscription count
int	getDurableMessageCount()
int	getDurableSubscriptionsCount()
java.util.List	getMessageCounters()
int	getNonDurableMessageCount()
int	getNonDurableSubscriptionsCount()
protected boolean	isQueue()
java.util.List	listAllMessages(java.lang.String subscriptionId)
java.util.List	listAllMessages(java.lang.String subscriptionId, java.lang.String selector)
java.util.List	listAllSubscriptions()
java.lang.String	listAllSubscriptionsAsHTML()
java.util.List	listDurableMessages(java.lang.String subscriptionId)
java.util.List	listDurableMessages(java.lang.String subscriptionId, java.lang.String selector)
java.util.List	listDurableSubscriptions()
java.lang.String	listDurableSubscriptionsAsHTML()
java.util.List	listNonDurableMessages(java.lang.String subscriptionId)
java.util.List	listNonDurableMessages(java.lang.String subscriptionId, java.lang.String selector)
java.util.List	listNonDurableSubscriptions()
java.lang.String	listNonDurableSubscriptionsAsHTML()
void	removeAllMessages() Remove all messages from subscription's storage.
void	startService()
void	stopService()

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

getDLQ, getDownCacheSize, getExpiryQueue, getFullSize, getInstance, getJNDIName, getMaxDeliveryAttempts, getMaxSize, getMessageCounterHistoryDayLimit, getName, getPageSize, getRedeliveryDelay, getSecurityConfig, getServerPeer, isClustered, isCreatedProgrammatically, listMessageCounterAsHTML, listMessageCounterHistoryAsHTML, setClustered, setDLQ, setDownCacheSize, setExpiryQueue, setFullSize, setJNDIName, setMaxDeliveryAttempts, setMaxSize, setMessageCounterHistoryDayLimit, setPageSize, setRedeliveryDelay, setSecurityConfig, setServerPeer, toString

Methods inherited from class java.lang.Object

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

Field Detail

SUBSCRIPTION_MESSAGECOUNTER_PREFIX

public static final java.lang.String SUBSCRIPTION_MESSAGECOUNTER_PREFIX

See Also:

Constant Field Values

Constructor Detail

TopicService

public TopicService()

TopicService

public TopicService(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

getAllMessageCount

public int getAllMessageCount()
                       throws java.lang.Exception

Specified by:

getAllMessageCount in interface TopicMBean

Throws:

java.lang.Exception

getDurableMessageCount

public int getDurableMessageCount()
                           throws java.lang.Exception

Specified by:

getDurableMessageCount in interface TopicMBean

Throws:

java.lang.Exception

getNonDurableMessageCount

public int getNonDurableMessageCount()
                              throws java.lang.Exception

Specified by:

getNonDurableMessageCount in interface TopicMBean

Throws:

java.lang.Exception

getAllSubscriptionsCount

public int getAllSubscriptionsCount()
                             throws java.lang.Exception

All subscription count

Specified by:

getAllSubscriptionsCount in interface TopicMBean

Returns:

all subscription count

Throws:

JMSException

java.lang.Exception

getDurableSubscriptionsCount

public int getDurableSubscriptionsCount()
                                 throws java.lang.Exception

Specified by:

getDurableSubscriptionsCount in interface TopicMBean

Throws:

java.lang.Exception

getNonDurableSubscriptionsCount

public int getNonDurableSubscriptionsCount()
                                    throws java.lang.Exception

Specified by:

getNonDurableSubscriptionsCount in interface TopicMBean

Throws:

java.lang.Exception

removeAllMessages

public void removeAllMessages()
                       throws java.lang.Exception

Remove all messages from subscription's storage.

Specified by:

removeAllMessages in interface DestinationMBean

Specified by:

removeAllMessages in interface TopicMBean

Specified by:

removeAllMessages in class DestinationServiceSupport

Throws:

java.lang.Exception

listAllSubscriptions

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

Specified by:

listAllSubscriptions in interface TopicMBean

Throws:

java.lang.Exception

listDurableSubscriptions

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

Specified by:

listDurableSubscriptions in interface TopicMBean

Throws:

java.lang.Exception

listNonDurableSubscriptions

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

Specified by:

listNonDurableSubscriptions in interface TopicMBean

Throws:

java.lang.Exception

listAllSubscriptionsAsHTML

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

Specified by:

listAllSubscriptionsAsHTML in interface TopicMBean

Throws:

java.lang.Exception

listDurableSubscriptionsAsHTML

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

Specified by:

listDurableSubscriptionsAsHTML in interface TopicMBean

Throws:

java.lang.Exception

listNonDurableSubscriptionsAsHTML

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

Specified by:

listNonDurableSubscriptionsAsHTML in interface TopicMBean

Throws:

java.lang.Exception

listAllMessages

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

Specified by:

listAllMessages in interface TopicMBean

Throws:

java.lang.Exception

listAllMessages

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

Specified by:

listAllMessages in interface TopicMBean

Throws:

java.lang.Exception

listDurableMessages

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

Specified by:

listDurableMessages in interface TopicMBean

Throws:

java.lang.Exception

listDurableMessages

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

Specified by:

listDurableMessages in interface TopicMBean

Throws:

java.lang.Exception

listNonDurableMessages

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

Specified by:

listNonDurableMessages in interface TopicMBean

Throws:

java.lang.Exception

listNonDurableMessages

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

Specified by:

listNonDurableMessages in interface TopicMBean

Throws:

java.lang.Exception

getMessageCounters

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

Specified by:

getMessageCounters in interface TopicMBean

Throws:

java.lang.Exception

isQueue

protected boolean isQueue()

Specified by:

isQueue in class DestinationServiceSupport