public class VirtualTopicInterceptor extends DestinationFilter
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
Constructor and Description |
---|
VirtualTopicInterceptor(Destination next,
java.lang.String prefix,
java.lang.String postfix) |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQDestination |
getQueueConsumersWildcard(ActiveMQDestination original) |
void |
send(ProducerBrokerExchange context,
Message message) |
acknowledge, addProducer, addSubscription, browse, dispose, fastProducer, gc, getActiveMQDestination, getBlockedProducerWarningInterval, getConsumers, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationStatistics, getMaxAuditDepth, getMaxBrowsePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, getSlowConsumerStrategy, isActive, isEnableAudit, isFull, isLazyDispatch, isPrioritizedMessages, isProducerFlowControl, isUseCache, iterate, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messageExpired, processDispatchNotification, removeProducer, removeSubscription, send, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setEnableAudit, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxPageSize, setMaxProducersToAudit, setMinimumMessageSize, setProducerFlowControl, setUseCache, slowConsumer, start, stop, wakeup
public VirtualTopicInterceptor(Destination next, java.lang.String prefix, java.lang.String postfix)
public void send(ProducerBrokerExchange context, Message message) throws java.lang.Exception
send
in interface Destination
send
in class DestinationFilter
java.lang.Exception
protected ActiveMQDestination getQueueConsumersWildcard(ActiveMQDestination original)
Copyright © 2005-2012. All Rights Reserved.