org.apache.qpid.server.exchange
Interface ExchangeRegistry

All Superinterfaces:
MessageRouter
All Known Implementing Classes:
DefaultExchangeRegistry

public interface ExchangeRegistry
extends MessageRouter


Method Summary
 Exchange getDefaultExchange()
           
 Exchange getExchange(org.apache.qpid.framing.AMQShortString name)
           
 Exchange getExchange(String exchangeName)
           
 Collection<org.apache.qpid.framing.AMQShortString> getExchangeNames()
           
 void initialise()
           
 void registerExchange(Exchange exchange)
           
 void setDefaultExchange(Exchange exchange)
           
 void unregisterExchange(org.apache.qpid.framing.AMQShortString name, boolean inUse)
          Unregister an exchange
 void unregisterExchange(String exchange, boolean ifUnused)
           
 
Methods inherited from interface org.apache.qpid.server.exchange.MessageRouter
routeContent
 

Method Detail

registerExchange

void registerExchange(Exchange exchange)
                      throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

unregisterExchange

void unregisterExchange(org.apache.qpid.framing.AMQShortString name,
                        boolean inUse)
                        throws ExchangeInUseException,
                               org.apache.qpid.AMQException
Unregister an exchange

Parameters:
name - name of the exchange to delete
inUse - if true, do NOT delete the exchange if it is in use (has queues bound to it)
Throws:
ExchangeInUseException - when the exchange cannot be deleted because it is in use
org.apache.qpid.AMQException

getExchange

Exchange getExchange(org.apache.qpid.framing.AMQShortString name)

setDefaultExchange

void setDefaultExchange(Exchange exchange)

getDefaultExchange

Exchange getDefaultExchange()

getExchangeNames

Collection<org.apache.qpid.framing.AMQShortString> getExchangeNames()

initialise

void initialise()
                throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

getExchange

Exchange getExchange(String exchangeName)

unregisterExchange

void unregisterExchange(String exchange,
                        boolean ifUnused)
                        throws ExchangeInUseException,
                               org.apache.qpid.AMQException
Throws:
ExchangeInUseException
org.apache.qpid.AMQException


Licensed to the Apache Software Foundation