public class SelectorAwareVirtualTopicInterceptor extends VirtualTopicInterceptor
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
Constructor and Description |
---|
SelectorAwareVirtualTopicInterceptor(Destination next,
String prefix,
String postfix,
boolean local) |
Modifier and Type | Method and Description |
---|---|
protected void |
send(ProducerBrokerExchange context,
Message message,
ActiveMQDestination destination)
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, send
acknowledge, addProducer, addSubscription, browse, canGC, dispose, fastProducer, gc, getActiveMQDestination, getBlockedProducerWarningInterval, getConsumers, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationStatistics, getInactiveTimoutBeforeGC, getMaxAuditDepth, getMaxBrowsePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, 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, setMinimumMessageSize, setProducerFlowControl, setUseCache, slowConsumer, start, stop, wakeup
public SelectorAwareVirtualTopicInterceptor(Destination next, String prefix, String postfix, boolean local)
protected void send(ProducerBrokerExchange context, Message message, ActiveMQDestination destination) throws Exception
send
in class DestinationFilter
context
- broker contextmessage
- message to senddestination
- possibly wildcard destination to send the message toException
- on errorCopyright © 2005–2014 The Apache Software Foundation. All rights reserved.