org.apache.qpid.extras.exchanges.example
Class TestExchange
java.lang.Object
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 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 |
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 |
TestExchange
public TestExchange()
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