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

java.lang.Object
  org.apache.activemq.broker.region.DestinationFilter
      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