org.apache.qpid.server.exchange.topic
Class TopicExchangeResult

java.lang.Object
  extended by org.apache.qpid.server.exchange.topic.TopicExchangeResult
All Implemented Interfaces:
TopicMatcherResult

public final class TopicExchangeResult
extends Object
implements TopicMatcherResult


Constructor Summary
TopicExchangeResult()
           
 
Method Summary
 void addBinding(Binding binding)
           
 void addFilteredQueue(AMQQueue queue, MessageFilter filter)
           
 void addUnfilteredQueue(AMQQueue queue)
           
 List<Binding> getBindings()
           
 Collection<AMQQueue> getUnfilteredQueues()
           
 Collection<AMQQueue> processMessage(InboundMessage msg, Collection<AMQQueue> queues)
           
 void removeBinding(Binding binding)
           
 void removeFilteredQueue(AMQQueue queue, MessageFilter filter)
           
 void removeUnfilteredQueue(AMQQueue queue)
           
 void replaceQueueFilter(AMQQueue queue, MessageFilter oldFilter, MessageFilter newFilter)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TopicExchangeResult

public TopicExchangeResult()
Method Detail

addUnfilteredQueue

public void addUnfilteredQueue(AMQQueue queue)

removeUnfilteredQueue

public void removeUnfilteredQueue(AMQQueue queue)

getUnfilteredQueues

public Collection<AMQQueue> getUnfilteredQueues()

addBinding

public void addBinding(Binding binding)

removeBinding

public void removeBinding(Binding binding)

getBindings

public List<Binding> getBindings()

addFilteredQueue

public void addFilteredQueue(AMQQueue queue,
                             MessageFilter filter)

removeFilteredQueue

public void removeFilteredQueue(AMQQueue queue,
                                MessageFilter filter)

replaceQueueFilter

public void replaceQueueFilter(AMQQueue queue,
                               MessageFilter oldFilter,
                               MessageFilter newFilter)

processMessage

public Collection<AMQQueue> processMessage(InboundMessage msg,
                                           Collection<AMQQueue> queues)


Licensed to the Apache Software Foundation