public class MirroredQueue extends java.lang.Object implements DestinationInterceptor, BrokerServiceAware
Constructor and Description |
---|
MirroredQueue() |
Modifier and Type | Method and Description |
---|---|
void |
create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
protected Destination |
getMirrorDestination(Destination destination) |
protected ActiveMQDestination |
getMirrorTopic(ActiveMQDestination original) |
java.lang.String |
getPostfix() |
java.lang.String |
getPrefix() |
Destination |
intercept(Destination destination) |
boolean |
isCopyMessage() |
void |
remove(Destination destination) |
void |
setBrokerService(BrokerService brokerService) |
void |
setCopyMessage(boolean copyMessage)
Sets whether a copy of the message will be sent to each destination.
|
void |
setPostfix(java.lang.String postfix)
Sets any postix used to identify the queue consumers
|
void |
setPrefix(java.lang.String prefix)
Sets the prefix wildcard used to identify the queue consumers for a given
topic
|
public MirroredQueue()
public Destination intercept(Destination destination)
intercept
in interface DestinationInterceptor
public void remove(Destination destination)
remove
in interface DestinationInterceptor
public void create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
create
in interface DestinationInterceptor
public java.lang.String getPostfix()
public void setPostfix(java.lang.String postfix)
public java.lang.String getPrefix()
public void setPrefix(java.lang.String prefix)
public boolean isCopyMessage()
public void setCopyMessage(boolean copyMessage)
public void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
protected Destination getMirrorDestination(Destination destination) throws java.lang.Exception
java.lang.Exception
protected ActiveMQDestination getMirrorTopic(ActiveMQDestination original)
Copyright © 2005-2012. All Rights Reserved.