org.apache.activemq.broker.region
Class DestinationFilter
java.lang.Object
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 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DestinationFilter
public DestinationFilter(Destination next)
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.