Package 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	Description
CompositeDestination()

Method Summary

Modifier and Type	Method	Description
void	create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
boolean	equals(Object obj)
Collection	getForwardTo()
ActiveMQDestination	getMappedDestinations()	Returns mapped destination(s)
String	getName()
int	hashCode()
Destination	intercept(Destination destination)	Creates a virtual destination from the physical destination
boolean	isConcurrentSend()
boolean	isCopyMessage()	Deprecated.
boolean	isForwardOnly()
boolean	isSendWhenNotMatched()
void	remove(Destination destination)
void	setConcurrentSend(boolean concurrentSend)	when true, sends are done in parallel with the broker executor
void	setCopyMessage(boolean copyMessage)	Deprecated. this option will be removed in a later release, message are always copied.
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
void	setSendWhenNotMatched(boolean sendWhenNotMatched)

Methods inherited from class java.lang.Object

clone, finalize, getClass, 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

@Deprecated
public boolean isCopyMessage()

Deprecated.

setCopyMessage

@Deprecated
public void setCopyMessage(boolean copyMessage)

Deprecated.

this option will be removed in a later release, message are always copied.

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

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

isSendWhenNotMatched

public boolean isSendWhenNotMatched()

setSendWhenNotMatched

public void setSendWhenNotMatched(boolean sendWhenNotMatched)