public class VirtualTopicInterceptor extends DestinationFilter
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
Constructor and Description |
---|
VirtualTopicInterceptor(Destination next,
String prefix,
String postfix,
boolean local) |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQDestination |
getQueueConsumersWildcard(ActiveMQDestination original) |
void |
send(ProducerBrokerExchange context,
Message message) |
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, send, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDoOptimzeMessageStorage, setEnableAudit, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxPageSize, setMaxProducersToAudit, setMinimumMessageSize, setProducerFlowControl, setUseCache, slowConsumer, start, stop, wakeup
public VirtualTopicInterceptor(Destination next, String prefix, String postfix, boolean local)
public void send(ProducerBrokerExchange context, Message message) throws Exception
send
in interface Destination
send
in class DestinationFilter
Exception
protected ActiveMQDestination getQueueConsumersWildcard(ActiveMQDestination original)
Copyright © 2005–2014 The Apache Software Foundation. All rights reserved.