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, 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 $

Field Summary
 
Fields inherited from class org.apache.activemq.broker.region.Queue
consumers, LOG, messages, messagesWaitingForSpace, taskFactory, taskRunner
 
Fields inherited from class org.apache.activemq.broker.region.BaseDestination
broker, brokerService, deadLetterStrategy, destination, destinationStatistics, MAX_BROWSE_PAGE_SIZE, MAX_PAGE_SIZE, memoryUsage, regionBroker, store, systemUsage
 
Fields inherited from interface org.apache.activemq.broker.region.Destination
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 initialize()
          initialize the destination
 
Methods inherited from class org.apache.activemq.broker.region.Queue
acknowledge, browse, copyMatchingMessages, copyMatchingMessagesTo, copyMatchingMessagesTo, copyMessageTo, createConnectionContext, createMessageIdFilter, createSelectorFilter, 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, dispose, fastProducer, getDeadLetterStrategy, getDestinationSequenceId, getDestinationStatistics, getMaxAuditDepth, getMaxBrowsePageSize, 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, setDeadLetterStrategy, setEnableAudit, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxPageSize, setMaxProducersToAudit, setMinimumMessageSize, setProducerFlowControl, setSendAdvisoryIfNoConsumers, setUseCache, slowConsumer
 
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


Copyright © 2009. All Rights Reserved.