public class TempQueue extends Queue
IndexListener.MessageContextconsumers, dispatchPendingList, messages, taskFactory, taskRunnerblockedProducerWarningInterval, 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, warnOnProducerFlowControlDEFAULT_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, doBrowseList, gc, getActiveMQDestination, getConsumers, getConsumersBeforeDispatchStarts, getDispatchPolicy, getLog, getMessage, getMessageGroupMapFactory, getMessageGroupOwners, getMessages, getTimeBeforeDispatchStarts, isAllConsumersExclusiveByDefault, isDispatchPaused, isOptimizedDispatch, isOptimizeStorage, isResetNeeded, isStrictOrderDispatch, isUseConsumerPriority, iterate, messageExpired, messageExpired, moveMatchingMessagesTo, moveMatchingMessagesTo, moveMatchingMessagesTo, moveMessageTo, moveMessageTo, onAdd, onUsageChanged, pageInMessages, pauseDispatch, processDispatchNotification, purge, removeMatchingMessages, removeMatchingMessages, removeMatchingMessages, removeMessage, removeMessage, removeMessage, removeMessage, removeSubscription, resumeDispatch, retryMessages, send, setAllConsumersExclusiveByDefault, setConsumersBeforeDispatchStarts, setDispatchPolicy, setMessageGroupMapFactory, setMessages, setOptimizedDispatch, setPrioritizedMessages, setStrictOrderDispatch, setTimeBeforeDispatchStarts, setUseConsumerPriority, start, stop, toString, wakeupaddProducer, canGC, convertToNonRangedAck, createConnectionContext, duplicateFromStore, fastProducer, getBlockedProducerWarningInterval, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationSequenceId, getDestinationStatistics, getExpireMessagesPeriod, getInactiveTimeoutBeforeGC, 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, isPersistJMSRedelivered, 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, setInactiveTimeoutBeforeGC, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxExpirePageSize, setMaxPageSize, setMaxProducersToAudit, setMemoryUsage, setMinimumMessageSize, setOptimizeMessageStoreInFlightLimit, setPersistJMSRedelivered, setProducerFlowControl, setReduceMemoryFootprint, setSendAdvisoryIfNoConsumers, setSlowConsumerStrategy, setStoreUsageHighWaterMark, setUseCache, slowConsumer, waitForSpace, waitForSpacepublic TempQueue(BrokerService brokerService, ActiveMQDestination destination, MessageStore store, DestinationStatistics parentStats, TaskRunnerFactory taskFactory) throws Exception
brokerService - destination - store - parentStats - taskFactory - Exceptionpublic void initialize() throws Exception
BaseDestinationinitialize in class QueueExceptionpublic void addSubscription(ConnectionContext context, Subscription sub) throws Exception
addSubscription in interface DestinationaddSubscription in class QueueExceptionpublic void dispose(ConnectionContext context) throws IOException
dispose in interface Destinationdispose in class BaseDestinationIOExceptionCopyright © 2005–2015 FuseSource, Corp.. All rights reserved.