org.apache.activemq.broker.region.virtual
public class CompositeDestinationFilter extends DestinationFilter
Destination
where send()s are replicated to
each Destination instance.DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
Constructor and Description |
---|
CompositeDestinationFilter(Destination next,
java.util.Collection forwardDestinations,
boolean forwardOnly,
boolean copyMessage) |
Modifier and Type | Method and Description |
---|---|
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 CompositeDestinationFilter(Destination next, java.util.Collection forwardDestinations, boolean forwardOnly, boolean copyMessage)
public void send(ProducerBrokerExchange context, Message message) throws java.lang.Exception
send
in interface Destination
send
in class DestinationFilter
java.lang.Exception
Copyright © 2005-2014. All Rights Reserved.