org.codehaus.activemq.service.impl
Class TransientTopicMessageContainerManager
java.lang.Object
org.codehaus.activemq.service.impl.MessageContainerManagerSupport
org.codehaus.activemq.service.impl.DurableTopicMessageContainerManager
org.codehaus.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.6 $
Methods inherited from class org.codehaus.activemq.service.impl.DurableTopicMessageContainerManager |
acknowledgeMessage, acknowledgeTransactedMessage, commitTransaction, createContainer, createDestination, createFilter, doAddMessageConsumer, loadAllMessageContainers, poll, recoverSubscriptions, redeliverMessage, rollbackTransaction |
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 Protique, Ltd.. All Rights Reserved.