org.apache.activemq.broker.region.virtual

Class CompositeDestination

java.lang.Object

org.apache.activemq.broker.region.virtual.CompositeDestination

All Implemented Interfaces:

DestinationInterceptor, VirtualDestination

Direct Known Subclasses:

CompositeQueue, CompositeTopic

public abstract class CompositeDestination
extends Object
implements VirtualDestination

Constructor Summary

Constructors

Constructor and Description
CompositeDestination()

Method Summary

Methods

Modifier and Type	Method and Description
void	create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
Collection	getForwardTo()
ActiveMQDestination	getMappedDestinations() Returns mapped destination(s)
String	getName()
Destination	intercept(Destination destination) Creates a virtual destination from the physical destination
boolean	isConcurrentSend()
boolean	isCopyMessage()
boolean	isForwardOnly()
void	remove(Destination destination)
void	setConcurrentSend(boolean concurrentSend) when true, sends are done in parallel with the broker executor
void	setCopyMessage(boolean copyMessage) Sets whether a copy of the message will be sent to each destination.
void	setForwardOnly(boolean forwardOnly) Sets if the virtual destination is forward only (and so there is no physical queue to match the virtual queue) or if there is also a physical queue with the same name).
void	setForwardTo(Collection forwardDestinations) Sets the list of destinations to forward to
void	setName(String name) Sets the name of this composite destination

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.broker.region.virtual.VirtualDestination

getVirtualDestination, interceptMappedDestination

Constructor Detail

CompositeDestination

public CompositeDestination()

Method Detail

intercept

public Destination intercept(Destination destination)

Description copied from interface: VirtualDestination

Creates a virtual destination from the physical destination

Specified by:

intercept in interface DestinationInterceptor

Specified by:

intercept in interface VirtualDestination

create

public void create(Broker broker,
          ConnectionContext context,
          ActiveMQDestination destination)

Specified by:

create in interface DestinationInterceptor

remove

public void remove(Destination destination)

Specified by:

remove in interface DestinationInterceptor

getName

public String getName()

setName

public void setName(String name)

Sets the name of this composite destination

getForwardTo

public Collection getForwardTo()

setForwardTo

public void setForwardTo(Collection forwardDestinations)

Sets the list of destinations to forward to

isForwardOnly

public boolean isForwardOnly()

setForwardOnly

public void setForwardOnly(boolean forwardOnly)

Sets if the virtual destination is forward only (and so there is no physical queue to match the virtual queue) or if there is also a physical queue with the same name).

isCopyMessage

public boolean isCopyMessage()

setCopyMessage

public void setCopyMessage(boolean copyMessage)

Sets whether a copy of the message will be sent to each destination. Defaults to true so that the forward destination is set as the destination of the message

setConcurrentSend

public void setConcurrentSend(boolean concurrentSend)

when true, sends are done in parallel with the broker executor

isConcurrentSend

public boolean isConcurrentSend()

getMappedDestinations

public ActiveMQDestination getMappedDestinations()

Description copied from interface: VirtualDestination

Returns mapped destination(s)

Specified by:

getMappedDestinations in interface VirtualDestination