org.apache.activemq.broker.region
Class TempQueue

java.lang.Object
  extended by org.apache.activemq.broker.region.BaseDestination
      extended by org.apache.activemq.broker.region.Queue
          extended by org.apache.activemq.broker.region.TempQueue
All Implemented Interfaces:
Destination, Message.MessageDestination, Service, Task, UsageListener

public class TempQueue
extends Queue

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


Field Summary
 
Fields inherited from class org.apache.activemq.broker.region.Queue
consumers, messages, pagedInPendingDispatch, redeliveredWaitingDispatch, taskFactory, taskRunner
 
Fields inherited from class org.apache.activemq.broker.region.BaseDestination
blockedProducerWarningInterval, broker, brokerService, cursorMemoryHighWaterMark, deadLetterStrategy, DEFAULT_INACTIVE_TIMEOUT_BEFORE_GC, destination, destinationStatistics, EXPIRE_MESSAGE_PERIOD, expireMessagesPeriod, MAX_AUDIT_DEPTH, MAX_BROWSE_PAGE_SIZE, MAX_PAGE_SIZE, MAX_PRODUCERS_TO_AUDIT, memoryUsage, regionBroker, scheduler, store, storeUsageHighWaterMark, systemUsage, warnOnProducerFlowControl
 
Fields inherited from interface org.apache.activemq.broker.region.Destination
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
 
Constructor Summary
TempQueue(BrokerService brokerService, ActiveMQDestination destination, MessageStore store, DestinationStatistics parentStats, TaskRunnerFactory taskFactory)
           
 
Method Summary
 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, gc, getActiveMQDestination, getConsumers, getConsumersBeforeDispatchStarts, getDispatchPolicy, getLog, getMessage, getMessageGroupMapFactory, getMessageGroupOwners, getMessages, getTimeBeforeDispatchStarts, isAllConsumersExclusiveByDefault, isOptimizedDispatch, isOptimizeStorage, isStrictOrderDispatch, isUseConsumerPriority, iterate, messageExpired, messageExpired, moveMatchingMessagesTo, moveMatchingMessagesTo, moveMatchingMessagesTo, moveMessageTo, moveMessageTo, onUsageChanged, pageInMessages, processDispatchNotification, purge, removeMatchingMessages, removeMatchingMessages, removeMatchingMessages, removeMessage, removeMessage, removeMessage, removeMessage, removeSubscription, retryMessages, send, setAllConsumersExclusiveByDefault, setConsumersBeforeDispatchStarts, setDispatchPolicy, setMessageGroupMapFactory, setMessages, setOptimizedDispatch, setPrioritizedMessages, setStrictOrderDispatch, setTimeBeforeDispatchStarts, setUseConsumerPriority, start, stop, toString, wakeup
 
Methods inherited from class org.apache.activemq.broker.region.BaseDestination
addProducer, canGC, convertToNonRangedAck, createConnectionContext, fastProducer, getBlockedProducerWarningInterval, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationSequenceId, getDestinationStatistics, getExpireMessagesPeriod, getInactiveTimoutBeforeGC, getMaxAuditDepth, getMaxBrowsePageSize, getMaxExpirePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, getOptimizeMessageStoreInFlightLimit, getSlowConsumerStrategy, getStoreUsageHighWaterMark, hasRegularConsumers, isActive, isAdvisoryForConsumed, isAdvisoryForDelivery, isAdvisoryForDiscardingMessages, isAdvisoryForFastProducers, isAdvisoryForSlowConsumers, isAdvisoryWhenFull, isAlwaysRetroactive, isDisposed, isDLQ, isDoOptimzeMessageStorage, isEnableAudit, isFull, isGcIfInactive, isGcWithNetworkConsumers, isLazyDispatch, isPrioritizedMessages, isProducerFlowControl, isReduceMemoryFootprint, isSendAdvisoryIfNoConsumers, isUseCache, markForGC, messageConsumed, messageDelivered, messageDiscarded, onMessageWithNoConsumers, removeProducer, setAdvisoryForConsumed, setAdvisoryForDelivery, setAdvisoryForDiscardingMessages, setAdvisoryForFastProducers, setAdvisoryForSlowConsumers, setAdvisoryWhenFull, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDeadLetterStrategy, setDoOptimzeMessageStorage, setEnableAudit, setExpireMessagesPeriod, setGcIfInactive, setGcWithNetworkConsumers, setInactiveTimoutBeforeGC, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxExpirePageSize, setMaxPageSize, setMaxProducersToAudit, setMemoryUsage, setMinimumMessageSize, setOptimizeMessageStoreInFlightLimit, setProducerFlowControl, setReduceMemoryFootprint, setSendAdvisoryIfNoConsumers, 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


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.