Package org.apache.activemq.broker.region

Class TempQueue

java.lang.Object

org.apache.activemq.broker.region.BaseDestination

org.apache.activemq.broker.region.Queue

org.apache.activemq.broker.region.TempQueue

All Implemented Interfaces:

Destination, Message.MessageDestination, Service, IndexListener, Task, UsageListener

public class TempQueue
extends Queue

The Queue is a List of MessageEntry objects that are dispatched to matching subscriptions.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.activemq.store.IndexListener

IndexListener.MessageContext

Field Summary

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

consumers, dispatchPendingList, messages, taskFactory, taskRunner

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
TempQueue(BrokerService brokerService, ActiveMQDestination destination, MessageStore store, DestinationStatistics parentStats, TaskRunnerFactory taskFactory)

Method Summary

Modifier and Type	Method	Description
void	addSubscription(ConnectionContext context, Subscription sub)
void	dispose(ConnectionContext context)
void	initialize()	initialize the destination

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

acknowledge, assignGroup, assignMessageGroup, browse, clearPendingMessages, copyMatchingMessages, copyMatchingMessagesTo, copyMatchingMessagesTo, copyMessageTo, createMessageIdFilter, createSelectorFilter, doBrowse, doBrowseList, gc, getActiveMQDestination, getConsumers, getConsumersBeforeDispatchStarts, getDispatchPolicy, getLog, getMessage, getMessageGroupMapFactory, getMessageGroupOwners, getMessages, getPendingMessageCount, getPendingMessageSize, getTimeBeforeDispatchStarts, isAllConsumersExclusiveByDefault, isDispatchPaused, isOptimizedDispatch, isOptimizeStorage, isResetNeeded, isStrictOrderDispatch, isUseConsumerPriority, iterate, messageExpired, messageExpired, moveMatchingMessagesTo, moveMatchingMessagesTo, moveMatchingMessagesTo, moveMessageTo, moveMessageTo, onAdd, onUsageChanged, pageInMessages, pauseDispatch, processDispatchNotification, purge, removeMatchingMessages, removeMatchingMessages, removeMatchingMessages, removeMessage, removeMessage, removeMessage, removeMessage, removeSubscription, resumeDispatch, retryMessages, rollbackPendingCursorAdditions, send, setAllConsumersExclusiveByDefault, setConsumersBeforeDispatchStarts, setDispatchPolicy, setMessageGroupMapFactory, setMessages, setOptimizedDispatch, setPrioritizedMessages, setStrictOrderDispatch, setTimeBeforeDispatchStarts, setUseConsumerPriority, singlePendingSend, start, stop, toString, wakeup

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

addProducer, canGC, convertToNonRangedAck, createConnectionContext, duplicateFromStore, fastProducer, getBlockedProducerWarningInterval, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationSequenceId, getDestinationStatistics, getExpireMessagesPeriod, getInactiveTimeoutBeforeGC, getMaxAuditDepth, getMaxBrowsePageSize, getMaxExpirePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, getOptimizeMessageStoreInFlightLimit, getSlowConsumerStrategy, getStoreUsageHighWaterMark, getSystemUsage, getTempUsage, hasRegularConsumers, isActive, isAdvisoryForConsumed, isAdvisoryForDelivery, isAdvisoryForDiscardingMessages, 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, onMessageWithNoConsumers, removeProducer, setAdvisoryForConsumed, setAdvisoryForDelivery, setAdvisoryForDiscardingMessages, setAdvisoryForFastProducers, setAdvisoryForSlowConsumers, setAdvisoryWhenFull, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDeadLetterStrategy, setDoOptimzeMessageStorage, setEnableAudit, setExpireMessagesPeriod, setGcIfInactive, setGcWithNetworkConsumers, setInactiveTimeoutBeforeGC, setIncludeBodyForAdvisory, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxExpirePageSize, setMaxPageSize, setMaxProducersToAudit, setMemoryUsage, setMinimumMessageSize, setOptimizeMessageStoreInFlightLimit, setPersistJMSRedelivered, 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

Constructor Detail

TempQueue

public TempQueue(BrokerService brokerService,
                 ActiveMQDestination destination,
                 MessageStore store,
                 DestinationStatistics parentStats,
                 TaskRunnerFactory taskFactory)
          throws Exception

Parameters:

brokerService -

destination -

store -

parentStats -

taskFactory -

Throws:

Exception

Method Detail

initialize

public void initialize()
                throws Exception

Description copied from class: BaseDestination

initialize the destination

Overrides:

initialize in class Queue

Throws:

Exception

addSubscription

public void addSubscription(ConnectionContext context,
                            Subscription sub)
                     throws Exception

Specified by:

addSubscription in interface Destination

Overrides:

addSubscription in class Queue

Throws:

Exception

dispose

public void dispose(ConnectionContext context)
             throws IOException

Specified by:

dispose in interface Destination

Overrides:

dispose in class BaseDestination

Throws:

IOException