public class CompositeDestinationFilter extends DestinationFilter
Destination
where send()s are replicated to
each Destination instance.next
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
Constructor and Description |
---|
CompositeDestinationFilter(Destination next,
Collection forwardDestinations,
boolean forwardOnly,
boolean concurrentSend) |
Modifier and Type | Method and Description |
---|---|
void |
send(ProducerBrokerExchange context,
Message message) |
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, send, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDoOptimzeMessageStorage, setEnableAudit, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxPageSize, setMaxProducersToAudit, setMemoryUsage, setMinimumMessageSize, setProducerFlowControl, setUseCache, slowConsumer, start, stop, wakeup
public CompositeDestinationFilter(Destination next, Collection forwardDestinations, boolean forwardOnly, boolean concurrentSend)
public void send(ProducerBrokerExchange context, Message message) throws Exception
send
in interface Destination
send
in class DestinationFilter
Exception
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.