public class SelectorAwareVirtualTopicInterceptor extends VirtualTopicInterceptor
next
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
Constructor and Description |
---|
SelectorAwareVirtualTopicInterceptor(Destination next,
VirtualTopic virtualTopic) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
shouldDispatch(Broker broker,
Message message,
Destination dest)
Respect the selectors of the subscriptions to ensure only matched messages are dispatched to
the virtual queues, hence there is no build up of unmatched messages on these destinations
|
getQueueConsumersWildcard, getTopic, send, send
acknowledge, addProducer, addSubscription, browse, canGC, clearPendingMessages, deleteSubscription, 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, removeSubscription, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDoOptimzeMessageStorage, setEnableAudit, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxPageSize, setMaxProducersToAudit, setMemoryUsage, setMinimumMessageSize, setProducerFlowControl, setUseCache, slowConsumer, start, stop, wakeup
public SelectorAwareVirtualTopicInterceptor(Destination next, VirtualTopic virtualTopic)
protected boolean shouldDispatch(Broker broker, Message message, Destination dest) throws IOException
shouldDispatch
in class VirtualTopicInterceptor
IOException
Copyright © 2005–2020 The Apache Software Foundation. All rights reserved.