org.apache.qpid.extras.exchanges.example
Class TestExchange

java.lang.Object
  extended by org.apache.qpid.extras.exchanges.example.TestExchange
All Implemented Interfaces:
org.apache.qpid.server.configuration.ConfiguredObject<org.apache.qpid.server.configuration.ExchangeConfigType,org.apache.qpid.server.configuration.ExchangeConfig>, org.apache.qpid.server.configuration.ExchangeConfig, org.apache.qpid.server.exchange.Exchange, org.apache.qpid.server.exchange.ExchangeReferrer

public class TestExchange
extends Object
implements org.apache.qpid.server.exchange.Exchange


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.exchange.Exchange
org.apache.qpid.server.exchange.Exchange.BindingListener, org.apache.qpid.server.exchange.Exchange.Task
 
Constructor Summary
TestExchange()
           
 
Method Summary
 void addBinding(org.apache.qpid.server.binding.Binding binding)
           
 void addBindingListener(org.apache.qpid.server.exchange.Exchange.BindingListener listener)
           
 void addCloseTask(org.apache.qpid.server.exchange.Exchange.Task task)
           
 void addReference(org.apache.qpid.server.exchange.ExchangeReferrer exchange)
           
 void close()
           
 org.apache.qpid.server.exchange.Exchange getAlternateExchange()
           
 Map<String,Object> getArguments()
           
 long getBindingCount()
           
 long getBindingCountHigh()
           
 Collection<org.apache.qpid.server.binding.Binding> getBindings()
           
 long getByteReceives()
           
 long getByteRoutes()
           
 org.apache.qpid.server.configuration.ExchangeConfigType getConfigType()
           
 long getCreateTime()
           
 UUID getId()
           
 long getMsgReceives()
           
 long getMsgRoutes()
           
 String getName()
           
 org.apache.qpid.framing.AMQShortString getNameShortString()
           
 org.apache.qpid.server.configuration.ConfiguredObject getParent()
           
 int getTicket()
           
 org.apache.qpid.server.exchange.ExchangeType getType()
           
 org.apache.qpid.framing.AMQShortString getTypeShortString()
           
 org.apache.qpid.server.configuration.VirtualHostConfig getVirtualHost()
           
 boolean hasBindings()
           
 boolean hasReferrers()
           
 void initialise(org.apache.qpid.server.virtualhost.VirtualHost host, org.apache.qpid.framing.AMQShortString name, boolean durable, boolean autoDelete)
           
 void initialise(org.apache.qpid.server.virtualhost.VirtualHost arg0, org.apache.qpid.framing.AMQShortString arg1, boolean arg2, int arg3, boolean arg4)
           
 boolean isAutoDelete()
           
 boolean isBound(org.apache.qpid.server.queue.AMQQueue queue)
           
 boolean isBound(org.apache.qpid.framing.AMQShortString routingKey)
           
 boolean isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.server.queue.AMQQueue queue)
           
 boolean isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.FieldTable arguments, org.apache.qpid.server.queue.AMQQueue queue)
           
 boolean isBound(String bindingKey)
           
 boolean isBound(String bindingKey, org.apache.qpid.server.queue.AMQQueue queue)
           
 boolean isDurable()
           
 void removeBinding(org.apache.qpid.server.binding.Binding binding)
           
 void removeBindingListener(org.apache.qpid.server.exchange.Exchange.BindingListener listener)
           
 void removeCloseTask(org.apache.qpid.server.exchange.Exchange.Task task)
           
 void removeReference(org.apache.qpid.server.exchange.ExchangeReferrer exchange)
           
 ArrayList<? extends org.apache.qpid.server.queue.BaseQueue> route(org.apache.qpid.server.message.InboundMessage message)
           
 void setAlternateExchange(org.apache.qpid.server.exchange.Exchange exchange)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TestExchange

public TestExchange()
Method Detail

close

public void close()
           throws org.apache.qpid.AMQException
Specified by:
close in interface org.apache.qpid.server.exchange.Exchange
Throws:
org.apache.qpid.AMQException

addBindingListener

public void addBindingListener(org.apache.qpid.server.exchange.Exchange.BindingListener listener)
Specified by:
addBindingListener in interface org.apache.qpid.server.exchange.Exchange

removeBindingListener

public void removeBindingListener(org.apache.qpid.server.exchange.Exchange.BindingListener listener)
Specified by:
removeBindingListener in interface org.apache.qpid.server.exchange.Exchange

getNameShortString

public org.apache.qpid.framing.AMQShortString getNameShortString()
Specified by:
getNameShortString in interface org.apache.qpid.server.exchange.Exchange

getTypeShortString

public org.apache.qpid.framing.AMQShortString getTypeShortString()
Specified by:
getTypeShortString in interface org.apache.qpid.server.exchange.Exchange

hasBindings

public boolean hasBindings()
Specified by:
hasBindings in interface org.apache.qpid.server.exchange.Exchange

isBound

public boolean isBound(String bindingKey,
                       org.apache.qpid.server.queue.AMQQueue queue)
Specified by:
isBound in interface org.apache.qpid.server.exchange.Exchange

isBound

public boolean isBound(String bindingKey)
Specified by:
isBound in interface org.apache.qpid.server.exchange.Exchange

addCloseTask

public void addCloseTask(org.apache.qpid.server.exchange.Exchange.Task task)
Specified by:
addCloseTask in interface org.apache.qpid.server.exchange.Exchange

removeCloseTask

public void removeCloseTask(org.apache.qpid.server.exchange.Exchange.Task task)
Specified by:
removeCloseTask in interface org.apache.qpid.server.exchange.Exchange

getAlternateExchange

public org.apache.qpid.server.exchange.Exchange getAlternateExchange()
Specified by:
getAlternateExchange in interface org.apache.qpid.server.configuration.ExchangeConfig
Specified by:
getAlternateExchange in interface org.apache.qpid.server.exchange.Exchange

getArguments

public Map<String,Object> getArguments()
Specified by:
getArguments in interface org.apache.qpid.server.configuration.ExchangeConfig

getBindingCount

public long getBindingCount()
Specified by:
getBindingCount in interface org.apache.qpid.server.configuration.ExchangeConfig

getBindingCountHigh

public long getBindingCountHigh()
Specified by:
getBindingCountHigh in interface org.apache.qpid.server.configuration.ExchangeConfig

getMsgReceives

public long getMsgReceives()
Specified by:
getMsgReceives in interface org.apache.qpid.server.configuration.ExchangeConfig

getMsgRoutes

public long getMsgRoutes()
Specified by:
getMsgRoutes in interface org.apache.qpid.server.configuration.ExchangeConfig

getByteReceives

public long getByteReceives()
Specified by:
getByteReceives in interface org.apache.qpid.server.configuration.ExchangeConfig

getByteRoutes

public long getByteRoutes()
Specified by:
getByteRoutes in interface org.apache.qpid.server.configuration.ExchangeConfig

getCreateTime

public long getCreateTime()
Specified by:
getCreateTime in interface org.apache.qpid.server.configuration.ConfiguredObject<org.apache.qpid.server.configuration.ExchangeConfigType,org.apache.qpid.server.configuration.ExchangeConfig>

setAlternateExchange

public void setAlternateExchange(org.apache.qpid.server.exchange.Exchange exchange)
Specified by:
setAlternateExchange in interface org.apache.qpid.server.exchange.Exchange

removeReference

public void removeReference(org.apache.qpid.server.exchange.ExchangeReferrer exchange)
Specified by:
removeReference in interface org.apache.qpid.server.exchange.Exchange

addReference

public void addReference(org.apache.qpid.server.exchange.ExchangeReferrer exchange)
Specified by:
addReference in interface org.apache.qpid.server.exchange.Exchange

hasReferrers

public boolean hasReferrers()
Specified by:
hasReferrers in interface org.apache.qpid.server.exchange.Exchange

addBinding

public void addBinding(org.apache.qpid.server.binding.Binding binding)
Specified by:
addBinding in interface org.apache.qpid.server.exchange.Exchange

removeBinding

public void removeBinding(org.apache.qpid.server.binding.Binding binding)
Specified by:
removeBinding in interface org.apache.qpid.server.exchange.Exchange

getBindings

public Collection<org.apache.qpid.server.binding.Binding> getBindings()
Specified by:
getBindings in interface org.apache.qpid.server.exchange.Exchange

initialise

public void initialise(org.apache.qpid.server.virtualhost.VirtualHost host,
                       org.apache.qpid.framing.AMQShortString name,
                       boolean durable,
                       boolean autoDelete)
                throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

getVirtualHost

public org.apache.qpid.server.configuration.VirtualHostConfig getVirtualHost()
Specified by:
getVirtualHost in interface org.apache.qpid.server.configuration.ExchangeConfig

getName

public String getName()
Specified by:
getName in interface org.apache.qpid.server.configuration.ExchangeConfig

getType

public org.apache.qpid.server.exchange.ExchangeType getType()
Specified by:
getType in interface org.apache.qpid.server.configuration.ExchangeConfig

isAutoDelete

public boolean isAutoDelete()
Specified by:
isAutoDelete in interface org.apache.qpid.server.configuration.ExchangeConfig
Specified by:
isAutoDelete in interface org.apache.qpid.server.exchange.Exchange

isBound

public boolean isBound(org.apache.qpid.framing.AMQShortString routingKey,
                       org.apache.qpid.framing.FieldTable arguments,
                       org.apache.qpid.server.queue.AMQQueue queue)
Specified by:
isBound in interface org.apache.qpid.server.exchange.Exchange

isBound

public boolean isBound(org.apache.qpid.framing.AMQShortString routingKey,
                       org.apache.qpid.server.queue.AMQQueue queue)
Specified by:
isBound in interface org.apache.qpid.server.exchange.Exchange

isBound

public boolean isBound(org.apache.qpid.framing.AMQShortString routingKey)
Specified by:
isBound in interface org.apache.qpid.server.exchange.Exchange

isBound

public boolean isBound(org.apache.qpid.server.queue.AMQQueue queue)
Specified by:
isBound in interface org.apache.qpid.server.exchange.Exchange

getId

public UUID getId()
Specified by:
getId in interface org.apache.qpid.server.configuration.ConfiguredObject<org.apache.qpid.server.configuration.ExchangeConfigType,org.apache.qpid.server.configuration.ExchangeConfig>

getConfigType

public org.apache.qpid.server.configuration.ExchangeConfigType getConfigType()
Specified by:
getConfigType in interface org.apache.qpid.server.configuration.ConfiguredObject<org.apache.qpid.server.configuration.ExchangeConfigType,org.apache.qpid.server.configuration.ExchangeConfig>

getParent

public org.apache.qpid.server.configuration.ConfiguredObject getParent()
Specified by:
getParent in interface org.apache.qpid.server.configuration.ConfiguredObject<org.apache.qpid.server.configuration.ExchangeConfigType,org.apache.qpid.server.configuration.ExchangeConfig>

isDurable

public boolean isDurable()
Specified by:
isDurable in interface org.apache.qpid.server.configuration.ConfiguredObject<org.apache.qpid.server.configuration.ExchangeConfigType,org.apache.qpid.server.configuration.ExchangeConfig>
Specified by:
isDurable in interface org.apache.qpid.server.exchange.Exchange

route

public ArrayList<? extends org.apache.qpid.server.queue.BaseQueue> route(org.apache.qpid.server.message.InboundMessage message)
Specified by:
route in interface org.apache.qpid.server.exchange.Exchange

getTicket

public int getTicket()
Specified by:
getTicket in interface org.apache.qpid.server.exchange.Exchange

initialise

public void initialise(org.apache.qpid.server.virtualhost.VirtualHost arg0,
                       org.apache.qpid.framing.AMQShortString arg1,
                       boolean arg2,
                       int arg3,
                       boolean arg4)
                throws org.apache.qpid.AMQException
Specified by:
initialise in interface org.apache.qpid.server.exchange.Exchange
Throws:
org.apache.qpid.AMQException


Licensed to the Apache Software Foundation