Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> service >> [ impl overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

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:

org.activemq.service.MessageContainerManager, org.activemq.service.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
private static org.apache.commons.logging.Log	log

 

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(org.activemq.store.PersistenceAdapter persistenceAdapter)

TransientTopicMessageContainerManager(org.activemq.store.PersistenceAdapter persistenceAdapter, org.activemq.service.SubscriptionContainer subscriptionContainer, org.activemq.filter.FilterFactory filterFactory, org.activemq.service.Dispatcher dispatcher)

 

Method Summary
void	addMessageConsumer(org.activemq.broker.BrokerClient client, org.activemq.message.ConsumerInfo info)
void	deleteSubscription(java.lang.String clientId, java.lang.String subscriberName)           Delete a durable subscriber
private  void	doSendMessage(org.activemq.broker.BrokerClient client, org.activemq.message.ActiveMQMessage message, org.activemq.message.ActiveMQDestination destination)
void	removeMessageConsumer(org.activemq.broker.BrokerClient client, org.activemq.message.ConsumerInfo info)
void	sendMessage(org.activemq.broker.BrokerClient client, org.activemq.message.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

 

Field Detail

log

private static final org.apache.commons.logging.Log log

Constructor Detail

TransientTopicMessageContainerManager

public TransientTopicMessageContainerManager(org.activemq.store.PersistenceAdapter persistenceAdapter)

---

TransientTopicMessageContainerManager

public TransientTopicMessageContainerManager(org.activemq.store.PersistenceAdapter persistenceAdapter,
                                             org.activemq.service.SubscriptionContainer subscriptionContainer,
                                             org.activemq.filter.FilterFactory filterFactory,
                                             org.activemq.service.Dispatcher dispatcher)

Method Detail

addMessageConsumer

public void addMessageConsumer(org.activemq.broker.BrokerClient client,
                               org.activemq.message.ConsumerInfo info)
                        throws javax.jms.JMSException

Specified by:

addMessageConsumer in interface org.activemq.service.MessageContainerManager

Overrides:

addMessageConsumer in class DurableTopicMessageContainerManager

---

removeMessageConsumer

public void removeMessageConsumer(org.activemq.broker.BrokerClient client,
                                  org.activemq.message.ConsumerInfo info)
                           throws javax.jms.JMSException

Specified by:

removeMessageConsumer in interface org.activemq.service.MessageContainerManager

Overrides:

removeMessageConsumer in class DurableTopicMessageContainerManager

---

sendMessage

public void sendMessage(org.activemq.broker.BrokerClient client,
                        org.activemq.message.ActiveMQMessage message)
                 throws javax.jms.JMSException

Specified by:

sendMessage in interface org.activemq.service.MessageContainerManager

Overrides:

sendMessage in class DurableTopicMessageContainerManager

---

doSendMessage

private void doSendMessage(org.activemq.broker.BrokerClient client,
                           org.activemq.message.ActiveMQMessage message,
                           org.activemq.message.ActiveMQDestination destination)
                    throws javax.jms.JMSException

---

deleteSubscription

public void deleteSubscription(java.lang.String clientId,
                               java.lang.String subscriberName)
                        throws javax.jms.JMSException

Delete a durable subscriber

Specified by:

deleteSubscription in interface org.activemq.service.MessageContainerManager

Overrides:

deleteSubscription in class DurableTopicMessageContainerManager

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> service >> [ impl overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---