org.apache.activemq.broker.region.virtual
Class VirtualTopic

java.lang.Object
  org.apache.activemq.broker.region.virtual.VirtualTopic

All Implemented Interfaces:

DestinationInterceptor, VirtualDestination

public class VirtualTopic
extends java.lang.Object
implements VirtualDestination

Creates Virtual Topics using a prefix and postfix. The virtual destination creates a wildcard that is then used to look up all active queue subscriptions which match.

Version:

$Revision: 426366 $

Constructor Summary

VirtualTopic()

Method Summary

java.lang.String	getName()
java.lang.String	getPostfix()
java.lang.String	getPrefix()
protected ActiveMQDestination	getQueueConsumersWildcard(ActiveMQDestination original)
ActiveMQDestination	getVirtualDestination() Returns the virtual destination
Destination	intercept(Destination destination) Creates a virtual destination from the physical destination
void	setName(java.lang.String name)
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

Methods inherited from class java.lang.Object

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

Constructor Detail

VirtualTopic

public VirtualTopic()

Method Detail

getVirtualDestination

public ActiveMQDestination getVirtualDestination()

Description copied from interface: VirtualDestination

Returns the virtual destination

Specified by:

getVirtualDestination in interface VirtualDestination

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

getPostfix

public java.lang.String getPostfix()

setPostfix

public void setPostfix(java.lang.String postfix)

Sets any postix used to identify the queue consumers

getPrefix

public java.lang.String getPrefix()

setPrefix

public void setPrefix(java.lang.String prefix)

Sets the prefix wildcard used to identify the queue consumers for a given topic

getName

public java.lang.String getName()

setName

public void setName(java.lang.String name)

getQueueConsumersWildcard

protected ActiveMQDestination getQueueConsumersWildcard(ActiveMQDestination original)