Package 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, TempDestination, org.apache.activemq.command.Message.MessageDestination, org.apache.activemq.Service, org.apache.activemq.thread.Task

public class TempTopic
extends Topic
implements org.apache.activemq.thread.Task, TempDestination

The Topic is a destination that sends a copy of a message to every active Subscription registered.

Field Summary

Fields inherited from class org.apache.activemq.broker.region.Topic

consumers, LOG

Fields inherited from class org.apache.activemq.broker.region.BaseDestination

blockedProducerWarningInterval, broker, brokerService, cursorMemoryHighWaterMark, deadLetterStrategy, DEFAULT_INACTIVE_TIMEOUT_BEFORE_GC, destination, destinationStatistics, DUPLICATE_FROM_STORE_MSG_PREFIX, EXPIRE_MESSAGE_PERIOD, expireMessagesPeriod, lastBlockedProducerWarnTime, MAX_AUDIT_DEPTH, MAX_BROWSE_PAGE_SIZE, MAX_PAGE_SIZE, MAX_PRODUCERS_TO_AUDIT, memoryUsage, regionBroker, scheduler, started, store, storeUsageHighWaterMark, systemUsage

Fields inherited from interface org.apache.activemq.broker.region.Destination

DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY

Constructor Summary

Constructors

Constructor	Description
TempTopic(BrokerService brokerService, org.apache.activemq.command.ActiveMQDestination destination, TopicMessageStore store, DestinationStatistics parentStats, org.apache.activemq.thread.TaskRunnerFactory taskFactory)

Method Summary

Modifier and Type	Method	Description
void	addSubscription(ConnectionContext context, Subscription sub)
void	initialize()	initialize the destination
boolean	isAllowTempDestinationStealing()
void	setAllowTempDestinationStealing(boolean allowTempDestinationStealing)

Methods inherited from class org.apache.activemq.broker.region.Topic

acknowledge, activate, browse, clearPendingMessages, deactivate, deleteSubscription, dispatch, doBrowse, gc, getConsumers, getDispatchPolicy, getDurableTopicSubs, getLog, getSubscriptionRecoveryPolicy, isOptimizeStorage, iterate, loadMessage, lock, messageExpired, recoverRetroactiveMessages, removeSubscription, send, setDispatchPolicy, setSubscriptionRecoveryPolicy, start, stop, toString, wakeup

Methods inherited from class org.apache.activemq.broker.region.BaseDestination

addProducer, canGC, convertToNonRangedAck, createConnectionContext, dispose, duplicateFromStore, fastProducer, getActiveMQDestination, getBlockedProducerWarningInterval, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationSequenceId, getDestinationStatistics, getExpireMessagesPeriod, getInactiveTimeoutBeforeGC, getMaxAuditDepth, getMaxBrowsePageSize, getMaxExpirePageSize, getMaxInflatedDataSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageInterceptorStrategy, getMessageStore, getMinimumMessageSize, getName, getOptimizeMessageStoreInFlightLimit, getSlowConsumerStrategy, getStoreUsageHighWaterMark, getSystemUsage, getTempUsage, hasRegularConsumers, isActive, isAdvancedMessageStatisticsEnabled, isAdvancedNetworkStatisticsEnabled, isAdvisoryForConsumed, isAdvisoryForDelivery, isAdvisoryForDiscardingMessages, isAdvisoryForDispatched, isAdvisoryForFastProducers, isAdvisoryForSlowConsumers, isAdvisoryWhenFull, isAlwaysRetroactive, isDisposed, isDLQ, isDoOptimzeMessageStorage, isEnableAudit, isFlowControlLogRequired, isFull, isGcIfInactive, isGcWithNetworkConsumers, isIncludeBodyForAdvisory, isLazyDispatch, isPersistJMSRedelivered, isPrioritizedMessages, isProducerFlowControl, isReduceMemoryFootprint, isSendAdvisoryIfNoConsumers, isSendDuplicateFromStoreToDLQ, isUseCache, markForGC, messageConsumed, messageDelivered, messageDiscarded, messageDispatched, onMessageWithNoConsumers, processDispatchNotification, removeProducer, setAdvancedMessageStatisticsEnabled, setAdvancedNetworkStatisticsEnabled, setAdvisoryForConsumed, setAdvisoryForDelivery, setAdvisoryForDiscardingMessages, setAdvisoryForDispatched, setAdvisoryForFastProducers, setAdvisoryForSlowConsumers, setAdvisoryWhenFull, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDeadLetterStrategy, setDoOptimzeMessageStorage, setEnableAudit, setExpireMessagesPeriod, setGcIfInactive, setGcWithNetworkConsumers, setInactiveTimeoutBeforeGC, setIncludeBodyForAdvisory, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxExpirePageSize, setMaxPageSize, setMaxProducersToAudit, setMemoryUsage, setMessageInterceptorStrategy, setMinimumMessageSize, setOptimizeMessageStoreInFlightLimit, setPersistJMSRedelivered, setPrioritizedMessages, setProducerFlowControl, setReduceMemoryFootprint, setSendAdvisoryIfNoConsumers, setSendDuplicateFromStoreToDLQ, setSlowConsumerStrategy, setStoreUsageHighWaterMark, setUseCache, slowConsumer, waitForSpace, waitForSpace

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.broker.region.Destination

acknowledge, addProducer, browse, canGC, clearPendingMessages, dispose, duplicateFromStore, fastProducer, gc, getActiveMQDestination, getBlockedProducerWarningInterval, getConsumers, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationStatistics, getInactiveTimeoutBeforeGC, getMaxAuditDepth, getMaxBrowsePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, getSlowConsumerStrategy, getTempUsage, isActive, isAdvancedMessageStatisticsEnabled, isAdvancedNetworkStatisticsEnabled, isAlwaysRetroactive, isDisposed, isDoOptimzeMessageStorage, isEnableAudit, isFull, isLazyDispatch, isPrioritizedMessages, isProducerFlowControl, isSendDuplicateFromStoreToDLQ, isUseCache, markForGC, messageConsumed, messageDelivered, messageDiscarded, messageDispatched, messageExpired, processDispatchNotification, removeProducer, removeSubscription, send, setAdvancedMessageStatisticsEnabled, setAdvancedNetworkStatisticsEnabled, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDoOptimzeMessageStorage, setEnableAudit, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxPageSize, setMaxProducersToAudit, setMemoryUsage, setMinimumMessageSize, setProducerFlowControl, setSendDuplicateFromStoreToDLQ, setUseCache, slowConsumer, wakeup

Methods inherited from interface org.apache.activemq.command.Message.MessageDestination

getMaxInflatedDataSize

Methods inherited from interface org.apache.activemq.Service

start, stop

Methods inherited from interface org.apache.activemq.thread.Task

iterate

Constructor Details

TempTopic

public TempTopic(BrokerService brokerService,
 org.apache.activemq.command.ActiveMQDestination destination,
 TopicMessageStore store,
 DestinationStatistics parentStats,
 org.apache.activemq.thread.TaskRunnerFactory taskFactory)
          throws Exception

Parameters:

brokerService -

destination -

store -

parentStats -

taskFactory -

Throws:

Exception

Method Details

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

isAllowTempDestinationStealing

public boolean isAllowTempDestinationStealing()

Specified by:

isAllowTempDestinationStealing in interface TempDestination

setAllowTempDestinationStealing

public void setAllowTempDestinationStealing(boolean allowTempDestinationStealing)

Specified by:

setAllowTempDestinationStealing in interface TempDestination