public class MappedQueueFilter extends DestinationFilter
next
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
Constructor and Description |
---|
MappedQueueFilter(ActiveMQDestination virtualDestination,
Destination destination) |
Modifier and Type | Method and Description |
---|---|
void |
addSubscription(ConnectionContext context,
Subscription sub) |
void |
deleteSubscription(ConnectionContext context,
SubscriptionKey key) |
void |
removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId) |
String |
toString() |
acknowledge, addProducer, browse, canGC, clearPendingMessages, dispose, duplicateFromStore, fastProducer, gc, getActiveMQDestination, getAdaptor, getBlockedProducerWarningInterval, getConsumers, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationStatistics, getInactiveTimeoutBeforeGC, getMaxAuditDepth, getMaxBrowsePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, getNext, getSlowConsumerStrategy, isActive, isAlwaysRetroactive, isDisposed, isDoOptimzeMessageStorage, isEnableAudit, isFull, isLazyDispatch, isPrioritizedMessages, isProducerFlowControl, isUseCache, iterate, markForGC, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messageExpired, processDispatchNotification, removeProducer, send, send, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDoOptimzeMessageStorage, setEnableAudit, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxPageSize, setMaxProducersToAudit, setMemoryUsage, setMinimumMessageSize, setProducerFlowControl, setUseCache, slowConsumer, start, stop, wakeup
public MappedQueueFilter(ActiveMQDestination virtualDestination, Destination destination)
public void addSubscription(ConnectionContext context, Subscription sub) throws Exception
addSubscription
in interface Destination
addSubscription
in class DestinationFilter
Exception
public void removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId) throws Exception
removeSubscription
in interface Destination
removeSubscription
in class DestinationFilter
Exception
public void deleteSubscription(ConnectionContext context, SubscriptionKey key) throws Exception
deleteSubscription
in class DestinationFilter
Exception
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.