org.activemq.service.impl
Class TransientTopicMessageContainerManager

java.lang.Object
  extended by org.activemq.service.impl.MessageContainerManagerSupport
      extended by org.activemq.service.impl.DurableTopicMessageContainerManager
          extended by org.activemq.service.impl.TransientTopicMessageContainerManager
All Implemented Interfaces:
MessageContainerManager, Service

public class TransientTopicMessageContainerManager
extends DurableTopicMessageContainerManager

A default implementation of a Broker of Topic messages for transient consumers

Version:
$Revision: 1.1.1.1 $

Field Summary
 
Fields inherited from class org.activemq.service.impl.DurableTopicMessageContainerManager
activeSubscriptions, filterFactory, subscriptionContainer
 
Fields inherited from class org.activemq.service.impl.MessageContainerManagerSupport
dispatcher, messageContainers
 
Constructor Summary
TransientTopicMessageContainerManager(PersistenceAdapter persistenceAdapter)
           
TransientTopicMessageContainerManager(PersistenceAdapter persistenceAdapter, SubscriptionContainer subscriptionContainer, FilterFactory filterFactory, Dispatcher dispatcher)
           
 
Method Summary
 void addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void deleteSubscription(String clientId, String subscriberName)
          Delete a durable subscriber
 void removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void sendMessage(BrokerClient client, ActiveMQMessage message)
           
 
Methods inherited from class org.activemq.service.impl.DurableTopicMessageContainerManager
acknowledgeMessage, createContainer, createDestination, createFilter, createMessageContainer, destroyMessageContainer, doAddMessageConsumer, equal, getLocalDestinations, isConsumerActiveOnDestination, loadAllMessageContainers, poll, recoverSubscriptions
 
Methods inherited from class org.activemq.service.impl.MessageContainerManagerSupport
getContainer, getDeadLetterPolicy, getDestinations, getMessageContainerAdmins, isMaintainDestinationStats, loadContainer, setDeadLetterPolicy, setMaintainDestinationStats, start, stop, updateAcknowledgeStats, updateSendStats
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TransientTopicMessageContainerManager

public TransientTopicMessageContainerManager(PersistenceAdapter persistenceAdapter)

TransientTopicMessageContainerManager

public TransientTopicMessageContainerManager(PersistenceAdapter persistenceAdapter,
                                             SubscriptionContainer subscriptionContainer,
                                             FilterFactory filterFactory,
                                             Dispatcher dispatcher)
Method Detail

addMessageConsumer

public void addMessageConsumer(BrokerClient client,
                               ConsumerInfo info)
                        throws JMSException
Specified by:
addMessageConsumer in interface MessageContainerManager
Overrides:
addMessageConsumer in class DurableTopicMessageContainerManager
Parameters:
client -
info -
Throws:
JMSException

removeMessageConsumer

public void removeMessageConsumer(BrokerClient client,
                                  ConsumerInfo info)
                           throws JMSException
Specified by:
removeMessageConsumer in interface MessageContainerManager
Overrides:
removeMessageConsumer in class DurableTopicMessageContainerManager
Parameters:
client -
info -
Throws:
JMSException

sendMessage

public void sendMessage(BrokerClient client,
                        ActiveMQMessage message)
                 throws JMSException
Specified by:
sendMessage in interface MessageContainerManager
Overrides:
sendMessage in class DurableTopicMessageContainerManager
Parameters:
client -
message -
Throws:
JMSException

deleteSubscription

public void deleteSubscription(String clientId,
                               String subscriberName)
                        throws JMSException
Delete a durable subscriber

Specified by:
deleteSubscription in interface MessageContainerManager
Overrides:
deleteSubscription in class DurableTopicMessageContainerManager
Parameters:
clientId -
subscriberName -
Throws:
JMSException - if the subscriber doesn't exist or is still active


Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.