org.apache.activemq.broker.region.virtual
Class CompositeDestinationFilter

java.lang.Object
  extended by org.apache.activemq.broker.region.DestinationFilter
      extended by org.apache.activemq.broker.region.virtual.CompositeDestinationFilter
All Implemented Interfaces:
Destination, Message.MessageDestination, Service, Task

public class CompositeDestinationFilter
extends DestinationFilter

Represents a composite Destination where send()s are replicated to each Destination instance.


Field Summary
 
Fields inherited from class org.apache.activemq.broker.region.DestinationFilter
next
 
Fields inherited from interface org.apache.activemq.broker.region.Destination
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
 
Constructor Summary
CompositeDestinationFilter(Destination next, Collection forwardDestinations, boolean forwardOnly, boolean copyMessage)
           
 
Method Summary
 void send(ProducerBrokerExchange context, Message message)
           
 
Methods inherited from class org.apache.activemq.broker.region.DestinationFilter
acknowledge, addProducer, addSubscription, browse, canGC, clearPendingMessages, deleteSubscription, dispose, fastProducer, gc, getActiveMQDestination, getBlockedProducerWarningInterval, getConsumers, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationStatistics, getInactiveTimoutBeforeGC, getMaxAuditDepth, getMaxBrowsePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, getSlowConsumerStrategy, isActive, isAlwaysRetroactive, isDisposed, isDLQ, 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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CompositeDestinationFilter

public CompositeDestinationFilter(Destination next,
                                  Collection forwardDestinations,
                                  boolean forwardOnly,
                                  boolean copyMessage)
Method Detail

send

public void send(ProducerBrokerExchange context,
                 Message message)
          throws Exception
Specified by:
send in interface Destination
Overrides:
send in class DestinationFilter
Throws:
Exception


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.