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

java.lang.Object
  org.apache.activemq.broker.region.DestinationFilter
      org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor

All Implemented Interfaces:

Destination, Service

public class VirtualTopicInterceptor
extends DestinationFilter

A Destination which implements Virtual Topic

Version:

$Revision: 426366 $

Constructor Summary

VirtualTopicInterceptor(Destination next, java.lang.String prefix, java.lang.String postfix)

Method Summary

protected ActiveMQDestination	getQueueConsumersWildcard(ActiveMQDestination original)
void	send(ConnectionContext context, Message message)

Methods inherited from class org.apache.activemq.broker.region.DestinationFilter

acknowledge, addSubscription, browse, dispose, gc, getActiveMQDestination, getDeadLetterStrategy, getDestinationStatistics, getName, getUsageManager, lock, removeSubscription, send, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

VirtualTopicInterceptor

public VirtualTopicInterceptor(Destination next,
                               java.lang.String prefix,
                               java.lang.String postfix)

Method Detail

send

public void send(ConnectionContext context,
                 Message message)
          throws java.lang.Exception

Specified by:

send in interface Destination

Overrides:

send in class DestinationFilter

Throws:

java.lang.Exception

getQueueConsumersWildcard

protected ActiveMQDestination getQueueConsumersWildcard(ActiveMQDestination original)