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, Service, Task, UsageListener
public class TempQueue
- extends Queue
The Queue is a List of MessageEntry objects that are dispatched to matching
subscriptions.
- Version:
- $Revision: 1.28 $
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.Queue |
acknowledge, browse, copyMatchingMessages, copyMatchingMessagesTo, copyMatchingMessagesTo, copyMessageTo, createConnectionContext, createMessageIdFilter, createSelectorFilter, doBrowse, gc, getActiveMQDestination, getConsumers, getConsumersBeforeDispatchStarts, getDispatchPolicy, getMessage, getMessageGroupMapFactory, getMessageGroupOwners, getMessages, getTimeBeforeDispatchStarts, isOptimizedDispatch, isStrictOrderDispatch, isUseConsumerPriority, iterate, messageExpired, messageExpired, moveMatchingMessagesTo, moveMatchingMessagesTo, moveMatchingMessagesTo, moveMessageTo, moveMessageTo, onUsageChanged, pageInMessages, processDispatchNotification, purge, removeMatchingMessages, removeMatchingMessages, removeMatchingMessages, removeMessage, removeMessage, removeMessage, removeMessage, removeSubscription, send, setConsumersBeforeDispatchStarts, setDispatchPolicy, setMessageGroupMapFactory, setMessages, setOptimizedDispatch, setStrictOrderDispatch, setTimeBeforeDispatchStarts, setUseConsumerPriority, start, stop, toString, wakeup |
Methods inherited from class org.apache.activemq.broker.region.BaseDestination |
addProducer, fastProducer, 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, removeProducer, setAdvisdoryForFastProducers, setAdvisoryForConsumed, setAdvisoryForDelivery, setAdvisoryForDiscardingMessages, setAdvisoryForSlowConsumers, setAdvisoryWhenFull, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDeadLetterStrategy, setEnableAudit, setExpireMessagesPeriod, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxExpirePageSize, setMaxPageSize, setMaxProducersToAudit, setMinimumMessageSize, setProducerFlowControl, setSendAdvisoryIfNoConsumers, setUseCache, slowConsumer |
TempQueue
public TempQueue(BrokerService brokerService,
ActiveMQDestination destination,
MessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory)
throws Exception
- Parameters:
brokerService
- destination
- store
- parentStats
- taskFactory
-
- Throws:
Exception
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
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.