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

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

public class CompositeDestinationInterceptor
extends DestinationFilter

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

Version:
$Revision: 426366 $

Constructor Summary
CompositeDestinationInterceptor(Destination next, java.util.Collection forwardDestinations, boolean forwardOnly, boolean copyMessage)
           
 
Method Summary
 void send(ConnectionContext context, Message message)
           
 
Methods inherited from class org.apache.activemq.broker.region.DestinationFilter
acknowledge, addSubscription, browse, dispose, gc, getActiveMQDestination, getDeadLetterStrategy, getDestinationStatistics, getName, getUsageManager, lock, removeSubscription, send, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CompositeDestinationInterceptor

public CompositeDestinationInterceptor(Destination next,
                                       java.util.Collection forwardDestinations,
                                       boolean forwardOnly,
                                       boolean copyMessage)
Method Detail

send

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


Copyright © 2009 Apache Software Foundation. All Rights Reserved.