public class VirtualTopic extends Object implements VirtualDestination
Constructor and Description |
---|
VirtualTopic() |
Modifier and Type | Method and Description |
---|---|
void |
create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
String |
getName() |
String |
getPostfix() |
String |
getPrefix() |
ActiveMQDestination |
getVirtualDestination()
Returns the virtual destination
|
Destination |
intercept(Destination destination)
Creates a virtual destination from the physical destination
|
boolean |
isLocal() |
boolean |
isSelectorAware() |
void |
remove(Destination destination) |
void |
setLocal(boolean local) |
void |
setName(String name) |
void |
setPostfix(String postfix)
Sets any postix used to identify the queue consumers
|
void |
setPrefix(String prefix)
Sets the prefix wildcard used to identify the queue consumers for a given
topic
|
void |
setSelectorAware(boolean selectorAware)
Indicates whether the selectors of consumers are used to determine dispatch
to a virtual destination, when true only messages matching an existing
consumer will be dispatched.
|
public ActiveMQDestination getVirtualDestination()
VirtualDestination
getVirtualDestination
in interface VirtualDestination
public Destination intercept(Destination destination)
VirtualDestination
intercept
in interface DestinationInterceptor
intercept
in interface VirtualDestination
public void create(Broker broker, ConnectionContext context, ActiveMQDestination destination) throws Exception
create
in interface DestinationInterceptor
Exception
public void remove(Destination destination)
remove
in interface DestinationInterceptor
public String getPostfix()
public void setPostfix(String postfix)
public String getPrefix()
public void setPrefix(String prefix)
public String getName()
public void setName(String name)
public void setSelectorAware(boolean selectorAware)
selectorAware
- when true take consumer selectors into considerationpublic boolean isSelectorAware()
public boolean isLocal()
public void setLocal(boolean local)
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.