org.apache.qpid.server.binding
Class BindingFactory

java.lang.Object
  extended by org.apache.qpid.server.binding.BindingFactory

public class BindingFactory
extends Object


Constructor Summary
BindingFactory(DurableConfigurationStore.Source configSource, Exchange defaultExchange)
           
BindingFactory(VirtualHost vhost)
           
 
Method Summary
 boolean addBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> arguments)
           
 Binding getBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> arguments)
           
 VirtualHost getVirtualHost()
           
 void removeBinding(Binding b)
           
 Binding removeBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> arguments)
           
 boolean replaceBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> arguments)
           
 void restoreBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> argumentMap)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BindingFactory

public BindingFactory(VirtualHost vhost)

BindingFactory

public BindingFactory(DurableConfigurationStore.Source configSource,
                      Exchange defaultExchange)
Method Detail

getVirtualHost

public VirtualHost getVirtualHost()

addBinding

public boolean addBinding(String bindingKey,
                          AMQQueue queue,
                          Exchange exchange,
                          Map<String,Object> arguments)
                   throws org.apache.qpid.AMQSecurityException,
                          org.apache.qpid.AMQInternalException
Throws:
org.apache.qpid.AMQSecurityException
org.apache.qpid.AMQInternalException

replaceBinding

public boolean replaceBinding(String bindingKey,
                              AMQQueue queue,
                              Exchange exchange,
                              Map<String,Object> arguments)
                       throws org.apache.qpid.AMQSecurityException,
                              org.apache.qpid.AMQInternalException
Throws:
org.apache.qpid.AMQSecurityException
org.apache.qpid.AMQInternalException

restoreBinding

public void restoreBinding(String bindingKey,
                           AMQQueue queue,
                           Exchange exchange,
                           Map<String,Object> argumentMap)
                    throws org.apache.qpid.AMQSecurityException,
                           org.apache.qpid.AMQInternalException
Throws:
org.apache.qpid.AMQSecurityException
org.apache.qpid.AMQInternalException

removeBinding

public void removeBinding(Binding b)
                   throws org.apache.qpid.AMQSecurityException,
                          org.apache.qpid.AMQInternalException
Throws:
org.apache.qpid.AMQSecurityException
org.apache.qpid.AMQInternalException

removeBinding

public Binding removeBinding(String bindingKey,
                             AMQQueue queue,
                             Exchange exchange,
                             Map<String,Object> arguments)
                      throws org.apache.qpid.AMQSecurityException,
                             org.apache.qpid.AMQInternalException
Throws:
org.apache.qpid.AMQSecurityException
org.apache.qpid.AMQInternalException

getBinding

public Binding getBinding(String bindingKey,
                          AMQQueue queue,
                          Exchange exchange,
                          Map<String,Object> arguments)


Licensed to the Apache Software Foundation