org.apache.activemq.broker.region
Class DestinationFilter

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

public class DestinationFilter
extends java.lang.Object
implements Destination

Version:
$Revision: 470695 $

Constructor Summary
DestinationFilter(Destination next)
           
 
Method Summary
 void acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void addSubscription(ConnectionContext context, Subscription sub)
           
 Message[] browse()
           
 void dispose(ConnectionContext context)
           
 void gc()
           
 ActiveMQDestination getActiveMQDestination()
           
 DeadLetterStrategy getDeadLetterStrategy()
           
 DestinationStatistics getDestinationStatistics()
           
 java.lang.String getName()
           
 UsageManager getUsageManager()
           
 boolean lock(MessageReference node, LockOwner lockOwner)
           
 void removeSubscription(ConnectionContext context, Subscription sub)
           
 void send(ConnectionContext context, Message messageSend)
           
protected  void send(ConnectionContext context, Message message, ActiveMQDestination destination)
          Sends a message to the given destination which may be a wildcard
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DestinationFilter

public DestinationFilter(Destination next)
Method Detail

acknowledge

public void acknowledge(ConnectionContext context,
                        Subscription sub,
                        MessageAck ack,
                        MessageReference node)
                 throws java.io.IOException
Specified by:
acknowledge in interface Destination
Throws:
java.io.IOException

addSubscription

public void addSubscription(ConnectionContext context,
                            Subscription sub)
                     throws java.lang.Exception
Specified by:
addSubscription in interface Destination
Throws:
java.lang.Exception

browse

public Message[] browse()
Specified by:
browse in interface Destination

dispose

public void dispose(ConnectionContext context)
             throws java.io.IOException
Specified by:
dispose in interface Destination
Throws:
java.io.IOException

gc

public void gc()
Specified by:
gc in interface Destination

getActiveMQDestination

public ActiveMQDestination getActiveMQDestination()
Specified by:
getActiveMQDestination in interface Destination

getDeadLetterStrategy

public DeadLetterStrategy getDeadLetterStrategy()
Specified by:
getDeadLetterStrategy in interface Destination

getDestinationStatistics

public DestinationStatistics getDestinationStatistics()
Specified by:
getDestinationStatistics in interface Destination

getName

public java.lang.String getName()
Specified by:
getName in interface Destination

getUsageManager

public UsageManager getUsageManager()
Specified by:
getUsageManager in interface Destination

lock

public boolean lock(MessageReference node,
                    LockOwner lockOwner)
Specified by:
lock in interface Destination

removeSubscription

public void removeSubscription(ConnectionContext context,
                               Subscription sub)
                        throws java.lang.Exception
Specified by:
removeSubscription in interface Destination
Throws:
java.lang.Exception

send

public void send(ConnectionContext context,
                 Message messageSend)
          throws java.lang.Exception
Specified by:
send in interface Destination
Throws:
java.lang.Exception

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface Service
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface Service
Throws:
java.lang.Exception

send

protected void send(ConnectionContext context,
                    Message message,
                    ActiveMQDestination destination)
             throws java.lang.Exception
Sends a message to the given destination which may be a wildcard

Throws:
java.lang.Exception


Copyright © 2009 Apache Software Foundation. All Rights Reserved.