Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » [javadoc | source]
org.apache.activemq.broker.region
public class: TempQueue [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.region.BaseDestination
      org.apache.activemq.broker.region.Queue
         org.apache.activemq.broker.region.TempQueue

All Implemented Interfaces:
    Task, UsageListener, Destination

The Queue is a List of MessageEntry objects that are dispatched to matching subscriptions.
Fields inherited from org.apache.activemq.broker.region.Queue:
LOG,  taskFactory,  taskRunner,  consumers,  messages,  messagesWaitingForSpace,  flowControlTimeoutMessages,  browserDispatches
Fields inherited from org.apache.activemq.broker.region.BaseDestination:
MAX_PAGE_SIZE,  MAX_BROWSE_PAGE_SIZE,  EXPIRE_MESSAGE_PERIOD,  destination,  broker,  store,  systemUsage,  memoryUsage,  warnOnProducerFlowControl,  blockedProducerWarningInterval,  destinationStatistics,  brokerService,  regionBroker,  deadLetterStrategy,  expireMessagesPeriod,  cursorMemoryHighWaterMark
Constructor:
 public TempQueue(BrokerService brokerService,
    ActiveMQDestination destination,
    MessageStore store,
    DestinationStatistics parentStats,
    TaskRunnerFactory taskFactory) throws Exception 
    Parameters:
    brokerService -
    destination -
    store -
    parentStats -
    taskFactory -
    Throws:
    Exception -
Method from org.apache.activemq.broker.region.TempQueue Summary:
addSubscription,   dispose,   initialize
Methods from org.apache.activemq.broker.region.Queue:
acknowledge,   addSubscription,   browse,   copyMatchingMessages,   copyMatchingMessagesTo,   copyMatchingMessagesTo,   copyMessageTo,   createConnectionContext,   createMessageIdFilter,   createSelectorFilter,   doBrowse,   doMessageSend,   gc,   getActiveMQDestination,   getConsumers,   getConsumersBeforeDispatchStarts,   getDispatchPolicy,   getMessage,   getMessageGroupMapFactory,   getMessageGroupOwners,   getMessages,   getNextBrowserDispatch,   getTimeBeforeDispatchStarts,   initialize,   isOptimizedDispatch,   isStrictOrderDispatch,   isUseConsumerPriority,   iterate,   loadMessage,   messageExpired,   messageExpired,   moveMatchingMessagesTo,   moveMatchingMessagesTo,   moveMatchingMessagesTo,   moveMessageTo,   moveMessageTo,   onUsageChanged,   pageInMessages,   processDispatchNotification,   purge,   removeMatchingMessages,   removeMatchingMessages,   removeMatchingMessages,   removeMessage,   removeMessage,   removeMessage,   removeMessage,   removeSubscription,   send,   sendMessage,   setConsumersBeforeDispatchStarts,   setDispatchPolicy,   setMessageGroupMapFactory,   setMessages,   setOptimizedDispatch,   setStrictOrderDispatch,   setTimeBeforeDispatchStarts,   setUseConsumerPriority,   start,   stop,   toString,   wakeup
Methods from org.apache.activemq.broker.region.BaseDestination:
addProducer,   dispose,   fastProducer,   getActiveMQDestination,   getBlockedProducerWarningInterval,   getCursorMemoryHighWaterMark,   getDeadLetterStrategy,   getDestinationSequenceId,   getDestinationStatistics,   getExpireMessagesPeriod,   getMaxAuditDepth,   getMaxBrowsePageSize,   getMaxExpirePageSize,   getMaxPageSize,   getMaxProducersToAudit,   getMemoryUsage,   getMessageStore,   getMinimumMessageSize,   getName,   initialize,   isActive,   isAdvisdoryForFastProducers,   isAdvisoryForConsumed,   isAdvisoryForDelivery,   isAdvisoryForDiscardingMessages,   isAdvisoryForSlowConsumers,   isAdvisoryWhenFull,   isEnableAudit,   isFull,   isLazyDispatch,   isProducerFlowControl,   isSendAdvisoryIfNoConsumers,   isUseCache,   messageConsumed,   messageDelivered,   messageDiscarded,   onMessageWithNoConsumers,   processDispatchNotification,   removeProducer,   setAdvisdoryForFastProducers,   setAdvisoryForConsumed,   setAdvisoryForDelivery,   setAdvisoryForDiscardingMessages,   setAdvisoryForSlowConsumers,   setAdvisoryWhenFull,   setBlockedProducerWarningInterval,   setCursorMemoryHighWaterMark,   setDeadLetterStrategy,   setEnableAudit,   setExpireMessagesPeriod,   setLazyDispatch,   setMaxAuditDepth,   setMaxBrowsePageSize,   setMaxExpirePageSize,   setMaxPageSize,   setMaxProducersToAudit,   setMinimumMessageSize,   setProducerFlowControl,   setSendAdvisoryIfNoConsumers,   setUseCache,   slowConsumer
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.TempQueue Detail:
 public  void addSubscription(ConnectionContext context,
    Subscription sub) throws Exception 
 public  void dispose(ConnectionContext context) throws IOException 
 public  void initialize() throws Exception