public class TempQueue extends Queue
consumers, messages, pagedInPendingDispatch, redeliveredWaitingDispatch, taskFactory, taskRunner
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
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
Constructor and Description |
---|
TempQueue(BrokerService brokerService,
ActiveMQDestination destination,
MessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory) |
Modifier and Type | Method and Description |
---|---|
void |
addSubscription(ConnectionContext context,
Subscription sub) |
void |
dispose(ConnectionContext context) |
void |
initialize()
initialize the destination
|
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, send, setAllConsumersExclusiveByDefault, setConsumersBeforeDispatchStarts, setDispatchPolicy, setMessageGroupMapFactory, setMessages, setOptimizedDispatch, setPrioritizedMessages, setStrictOrderDispatch, setTimeBeforeDispatchStarts, setUseConsumerPriority, start, stop, toString, wakeup
addProducer, canGC, createConnectionContext, fastProducer, getBlockedProducerWarningInterval, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationSequenceId, getDestinationStatistics, getExpireMessagesPeriod, getInactiveTimoutBeforeGC, getMaxAuditDepth, getMaxBrowsePageSize, getMaxExpirePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, getOptimizeMessageStoreInFlightLimit, getSlowConsumerStrategy, getStoreUsageHighWaterMark, hasRegularConsumers, isActive, isAdvisdoryForFastProducers, isAdvisoryForConsumed, isAdvisoryForDelivery, isAdvisoryForDiscardingMessages, isAdvisoryForSlowConsumers, isAdvisoryWhenFull, isAlwaysRetroactive, isDisposed, isDoOptimzeMessageStorage, isEnableAudit, isFull, isGcIfInactive, isGcWithNetworkConsumers, isLazyDispatch, isPrioritizedMessages, isProducerFlowControl, isReduceMemoryFootprint, isSendAdvisoryIfNoConsumers, isUseCache, markForGC, messageConsumed, messageDelivered, messageDiscarded, onMessageWithNoConsumers, removeProducer, setAdvisdoryForFastProducers, setAdvisoryForConsumed, setAdvisoryForDelivery, setAdvisoryForDiscardingMessages, setAdvisoryForSlowConsumers, setAdvisoryWhenFull, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDeadLetterStrategy, setDoOptimzeMessageStorage, setEnableAudit, setExpireMessagesPeriod, setGcIfInactive, setGcWithNetworkConsumers, setInactiveTimoutBeforeGC, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxExpirePageSize, setMaxPageSize, setMaxProducersToAudit, setMinimumMessageSize, setOptimizeMessageStoreInFlightLimit, setProducerFlowControl, setReduceMemoryFootprint, setSendAdvisoryIfNoConsumers, setSlowConsumerStrategy, setStoreUsageHighWaterMark, setUseCache, slowConsumer, waitForSpace, waitForSpace
public TempQueue(BrokerService brokerService, ActiveMQDestination destination, MessageStore store, DestinationStatistics parentStats, TaskRunnerFactory taskFactory) throws java.lang.Exception
brokerService
- destination
- store
- parentStats
- taskFactory
- java.lang.Exception
public void initialize() throws java.lang.Exception
BaseDestination
initialize
in class Queue
java.lang.Exception
public void addSubscription(ConnectionContext context, Subscription sub) throws java.lang.Exception
addSubscription
in interface Destination
addSubscription
in class Queue
java.lang.Exception
public void dispose(ConnectionContext context) throws java.io.IOException
dispose
in interface Destination
dispose
in class BaseDestination
java.io.IOException
Copyright © 2005-2017. All Rights Reserved.