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

java.lang.Object
  extended by 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)


Copyright © 2011 Apache Software Foundation. All Rights Reserved.