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) |
boolean |
equals(Object obj) |
ActiveMQDestination |
getMappedDestinations()
Returns mapped destination(s)
|
String |
getName() |
String |
getPostfix() |
String |
getPrefix() |
ActiveMQDestination |
getVirtualDestination()
Returns the virtual destination
|
int |
hashCode() |
Destination |
intercept(Destination destination)
Creates a virtual destination from the physical destination
|
Destination |
interceptMappedDestination(Destination destination)
Creates a mapped destination
|
boolean |
isConcurrentSend() |
boolean |
isLocal() |
boolean |
isSelectorAware() |
boolean |
isTransactedSend() |
void |
remove(Destination destination) |
void |
setConcurrentSend(boolean concurrentSend)
When true, dispatch to matching destinations in parallel (in multiple threads)
|
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.
|
void |
setTransactedSend(boolean transactedSend)
When true, dispatch to matching destinations always uses a transaction.
|
String |
toString() |
public VirtualTopic()
public ActiveMQDestination getVirtualDestination()
VirtualDestination
getVirtualDestination
in interface VirtualDestination
public Destination intercept(Destination destination)
VirtualDestination
intercept
in interface DestinationInterceptor
intercept
in interface VirtualDestination
public ActiveMQDestination getMappedDestinations()
VirtualDestination
getMappedDestinations
in interface VirtualDestination
public Destination interceptMappedDestination(Destination destination)
VirtualDestination
interceptMappedDestination
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 void setPrefix(String prefix)
public void setSelectorAware(boolean selectorAware)
selectorAware
- when true take consumer selectors into considerationpublic boolean isSelectorAware()
public boolean isLocal()
public void setLocal(boolean local)
public boolean isConcurrentSend()
public void setConcurrentSend(boolean concurrentSend)
concurrentSend
- public boolean isTransactedSend()
public void setTransactedSend(boolean transactedSend)
transactedSend
- Copyright © 2005–2020 The Apache Software Foundation. All rights reserved.