public class VirtualTopicInterceptor extends DestinationFilter
next
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
Constructor and Description |
---|
VirtualTopicInterceptor(Destination next,
VirtualTopic virtualTopic) |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQDestination |
getQueueConsumersWildcard(ActiveMQDestination original) |
Topic |
getTopic() |
void |
send(ProducerBrokerExchange context,
Message message) |
protected void |
send(ProducerBrokerExchange context,
Message message,
ActiveMQDestination destination)
Sends a message to the given destination which may be a wildcard
|
protected boolean |
shouldDispatch(Broker broker,
Message message,
Destination dest) |
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 VirtualTopicInterceptor(Destination next, VirtualTopic virtualTopic)
public void send(ProducerBrokerExchange context, Message message) throws Exception
send
in interface Destination
send
in class DestinationFilter
Exception
protected void send(ProducerBrokerExchange context, Message message, ActiveMQDestination destination) throws Exception
DestinationFilter
send
in class DestinationFilter
context
- broker contextmessage
- message to senddestination
- possibly wildcard destination to send the message toException
- on errorprotected boolean shouldDispatch(Broker broker, Message message, Destination dest) throws IOException
IOException
protected ActiveMQDestination getQueueConsumersWildcard(ActiveMQDestination original)
Copyright © 2005–2018 The Apache Software Foundation. All rights reserved.