org.apache.activemq.broker.region
Class TempTopic
java.lang.Object
org.apache.activemq.broker.region.BaseDestination
org.apache.activemq.broker.region.Topic
org.apache.activemq.broker.region.TempTopic
- All Implemented Interfaces:
- Destination, Service, Task
public class TempTopic
- extends Topic
- implements Task
The Topic is a destination that sends a copy of a message to every active
Subscription registered.
- Version:
- $Revision: 1.21 $
Fields inherited from class org.apache.activemq.broker.region.BaseDestination |
blockedProducerWarningInterval, broker, brokerService, cursorMemoryHighWaterMark, deadLetterStrategy, destination, destinationStatistics, EXPIRE_MESSAGE_PERIOD, expireMessagesPeriod, MAX_BROWSE_PAGE_SIZE, MAX_PAGE_SIZE, memoryUsage, regionBroker, store, systemUsage, warnOnProducerFlowControl |
Methods inherited from class org.apache.activemq.broker.region.Topic |
acknowledge, activate, browse, deactivate, deleteSubscription, dispatch, gc, getConsumers, getDispatchPolicy, getSubscriptionRecoveryPolicy, iterate, loadMessage, lock, messageExpired, recoverRetroactiveMessages, removeSubscription, send, setDispatchPolicy, setSubscriptionRecoveryPolicy, start, stop, toString, wakeup |
Methods inherited from class org.apache.activemq.broker.region.BaseDestination |
addProducer, dispose, fastProducer, getActiveMQDestination, getBlockedProducerWarningInterval, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationSequenceId, getDestinationStatistics, getExpireMessagesPeriod, getMaxAuditDepth, getMaxBrowsePageSize, getMaxExpirePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, isActive, isAdvisdoryForFastProducers, isAdvisoryForConsumed, isAdvisoryForDelivery, isAdvisoryForDiscardingMessages, isAdvisoryForSlowConsumers, isAdvisoryWhenFull, isEnableAudit, isFull, isLazyDispatch, isProducerFlowControl, isSendAdvisoryIfNoConsumers, isUseCache, messageConsumed, messageDelivered, messageDiscarded, onMessageWithNoConsumers, processDispatchNotification, removeProducer, setAdvisdoryForFastProducers, setAdvisoryForConsumed, setAdvisoryForDelivery, setAdvisoryForDiscardingMessages, setAdvisoryForSlowConsumers, setAdvisoryWhenFull, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDeadLetterStrategy, setEnableAudit, setExpireMessagesPeriod, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxExpirePageSize, setMaxPageSize, setMaxProducersToAudit, setMinimumMessageSize, setProducerFlowControl, setSendAdvisoryIfNoConsumers, setUseCache, slowConsumer |
Methods inherited from interface org.apache.activemq.thread.Task |
iterate |
TempTopic
public TempTopic(BrokerService brokerService,
ActiveMQDestination destination,
TopicMessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory)
throws Exception
- Parameters:
brokerService
- destination
- store
- parentStats
- taskFactory
-
- Throws:
Exception
addSubscription
public void addSubscription(ConnectionContext context,
Subscription sub)
throws Exception
- Specified by:
addSubscription
in interface Destination
- Overrides:
addSubscription
in class Topic
- Throws:
Exception
initialize
public void initialize()
- Description copied from class:
BaseDestination
- initialize the destination
- Overrides:
initialize
in class Topic
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.