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

java.lang.Object
  extended by org.apache.activemq.broker.region.DestinationFilter
      extended by org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor
All Implemented Interfaces:
Destination, Service, Task
Direct Known Subclasses:
SelectorAwareVirtualTopicInterceptor

public class VirtualTopicInterceptor
extends DestinationFilter

A Destination which implements Virtual Topic


Field Summary
 
Fields inherited from interface org.apache.activemq.broker.region.Destination
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY
 
Constructor Summary
VirtualTopicInterceptor(Destination next, String prefix, String postfix, boolean local)
           
 
Method Summary
protected  ActiveMQDestination getQueueConsumersWildcard(ActiveMQDestination original)
           
 void send(ProducerBrokerExchange context, Message message)
           
 
Methods inherited from class org.apache.activemq.broker.region.DestinationFilter
acknowledge, addProducer, addSubscription, browse, canGC, clearPendingMessages, dispose, fastProducer, gc, getActiveMQDestination, getBlockedProducerWarningInterval, getConsumers, getCursorMemoryHighWaterMark, getDeadLetterStrategy, getDestinationStatistics, getInactiveTimoutBeforeGC, getMaxAuditDepth, getMaxBrowsePageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryUsage, getMessageStore, getMinimumMessageSize, getName, getSlowConsumerStrategy, isActive, isAlwaysRetroactive, isDisposed, isDoOptimzeMessageStorage, isEnableAudit, isFull, isLazyDispatch, isPrioritizedMessages, isProducerFlowControl, isUseCache, iterate, markForGC, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messageExpired, processDispatchNotification, removeProducer, removeSubscription, send, setAlwaysRetroactive, setBlockedProducerWarningInterval, setCursorMemoryHighWaterMark, setDoOptimzeMessageStorage, setEnableAudit, setLazyDispatch, setMaxAuditDepth, setMaxBrowsePageSize, setMaxPageSize, setMaxProducersToAudit, setMinimumMessageSize, setProducerFlowControl, setUseCache, slowConsumer, start, stop, wakeup
 
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,
                               String prefix,
                               String postfix,
                               boolean local)
Method Detail

send

public void send(ProducerBrokerExchange context,
                 Message message)
          throws Exception
Specified by:
send in interface Destination
Overrides:
send in class DestinationFilter
Throws:
Exception

getQueueConsumersWildcard

protected ActiveMQDestination getQueueConsumersWildcard(ActiveMQDestination original)


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.