org.activemq.service.impl
Class TransientTopicMessageContainerManager
java.lang.Object
org.activemq.service.impl.MessageContainerManagerSupport
org.activemq.service.impl.DurableTopicMessageContainerManager
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 $
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 |
TransientTopicMessageContainerManager
public TransientTopicMessageContainerManager(PersistenceAdapter persistenceAdapter)
TransientTopicMessageContainerManager
public TransientTopicMessageContainerManager(PersistenceAdapter persistenceAdapter,
SubscriptionContainer subscriptionContainer,
FilterFactory filterFactory,
Dispatcher dispatcher)
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-2007 Protique, Ltd.. All Rights Reserved.