org.apache.qpid.qmf
Class ManagementExchange

java.lang.Object
  extended by org.apache.qpid.qmf.ManagementExchange
All Implemented Interfaces:
QMFService.Listener, ConfiguredObject<ExchangeConfigType,ExchangeConfig>, ExchangeConfig, Exchange, ExchangeReferrer

public class ManagementExchange
extends Object
implements Exchange, QMFService.Listener


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.exchange.Exchange
Exchange.BindingListener, Exchange.Task
 
Field Summary
static ExchangeType<ManagementExchange> TYPE
           
 
Constructor Summary
ManagementExchange()
           
 
Method Summary
 void addBinding(Binding b)
           
 void addBindingListener(Exchange.BindingListener listener)
           
 void addCloseTask(Exchange.Task task)
           
 void addReference(ExchangeReferrer exchange)
           
 void close()
           
 Exchange getAlternateExchange()
           
 Map<String,Object> getArguments()
           
 long getBindingCount()
           
 long getBindingCountHigh()
           
 Collection<Binding> getBindings()
           
 long getByteReceives()
           
 long getByteRoutes()
           
 ConfigStore getConfigStore()
           
 ExchangeConfigType getConfigType()
           
 long getCreateTime()
           
 UUID getId()
           
 long getMsgReceives()
           
 long getMsgRoutes()
           
 String getName()
           
 org.apache.qpid.framing.AMQShortString getNameShortString()
           
 ConfiguredObject getParent()
           
 int getTicket()
           
 ExchangeType getType()
           
 org.apache.qpid.framing.AMQShortString getTypeShortString()
           
 VirtualHost getVirtualHost()
           
 boolean hasBindings()
          Returns true if this exchange has at least one binding associated with it.
 boolean hasReferrers()
           
 void initialise(VirtualHost host, org.apache.qpid.framing.AMQShortString name, boolean durable, int ticket, boolean autoDelete)
           
 boolean isAutoDelete()
           
 boolean isBound(AMQQueue queue)
           
 boolean isBound(org.apache.qpid.framing.AMQShortString routingKey)
          Determines whether a message is routing to any queue using a specific _routing key
 boolean isBound(org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue)
          Determines whether a message would be isBound to a particular queue using a specific routing key
 boolean isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.FieldTable arguments, AMQQueue queue)
          Determines whether a message would be isBound to a particular queue using a specific routing key and arguments
 boolean isBound(String bindingKey)
           
 boolean isBound(String bindingKey, AMQQueue queue)
           
 boolean isDurable()
           
 void objectCreated(QMFObject obj)
           
 void objectDeleted(QMFObject obj)
           
(package private)  void publishAllConsole()
           
(package private)  void publishAllSchema()
           
(package private)  void publishObjectsToConsole(long sampleTime, Collection<QMFObject> qmfObjects)
           
 void removeBinding(Binding binding)
           
 void removeBindingListener(Exchange.BindingListener listener)
           
 void removeCloseTask(Exchange.Task task)
           
 void removeReference(ExchangeReferrer exchange)
           
 ArrayList<BaseQueue> route(InboundMessage message)
           
 void setAlternateExchange(Exchange exchange)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

TYPE

public static final ExchangeType<ManagementExchange> TYPE
Constructor Detail

ManagementExchange

public ManagementExchange()
Method Detail

getNameShortString

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

getTypeShortString

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

initialise

public void initialise(VirtualHost host,
                       org.apache.qpid.framing.AMQShortString name,
                       boolean durable,
                       int ticket,
                       boolean autoDelete)
                throws org.apache.qpid.AMQException
Specified by:
initialise in interface Exchange
Throws:
org.apache.qpid.AMQException

getId

public UUID getId()
Specified by:
getId in interface ConfiguredObject<ExchangeConfigType,ExchangeConfig>

getConfigType

public ExchangeConfigType getConfigType()
Specified by:
getConfigType in interface ConfiguredObject<ExchangeConfigType,ExchangeConfig>

getParent

public ConfiguredObject getParent()
Specified by:
getParent in interface ConfiguredObject<ExchangeConfigType,ExchangeConfig>

isDurable

public boolean isDurable()
Specified by:
isDurable in interface ConfiguredObject<ExchangeConfigType,ExchangeConfig>
Specified by:
isDurable in interface Exchange

getVirtualHost

public VirtualHost getVirtualHost()
Specified by:
getVirtualHost in interface ExchangeConfig

getName

public String getName()
Specified by:
getName in interface ExchangeConfig

getType

public ExchangeType getType()
Specified by:
getType in interface ExchangeConfig

isAutoDelete

public boolean isAutoDelete()
Specified by:
isAutoDelete in interface ExchangeConfig
Specified by:
isAutoDelete in interface Exchange
Returns:
true if the exchange will be deleted after all queues have been detached

getTicket

public int getTicket()
Specified by:
getTicket in interface Exchange

close

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

getConfigStore

public ConfigStore getConfigStore()

addBinding

public void addBinding(Binding b)
Specified by:
addBinding in interface Exchange

publishAllConsole

void publishAllConsole()

publishObjectsToConsole

void publishObjectsToConsole(long sampleTime,
                             Collection<QMFObject> qmfObjects)

publishAllSchema

void publishAllSchema()

removeBinding

public void removeBinding(Binding binding)
Specified by:
removeBinding in interface Exchange

getBindings

public Collection<Binding> getBindings()
Specified by:
getBindings in interface Exchange

route

public ArrayList<BaseQueue> route(InboundMessage message)
Specified by:
route in interface Exchange

isBound

public boolean isBound(org.apache.qpid.framing.AMQShortString routingKey,
                       org.apache.qpid.framing.FieldTable arguments,
                       AMQQueue queue)
Description copied from interface: Exchange
Determines whether a message would be isBound to a particular queue using a specific routing key and arguments

Specified by:
isBound in interface Exchange
Returns:

isBound

public boolean isBound(org.apache.qpid.framing.AMQShortString routingKey,
                       AMQQueue queue)
Description copied from interface: Exchange
Determines whether a message would be isBound to a particular queue using a specific routing key

Specified by:
isBound in interface Exchange
Returns:

isBound

public boolean isBound(org.apache.qpid.framing.AMQShortString routingKey)
Description copied from interface: Exchange
Determines whether a message is routing to any queue using a specific _routing key

Specified by:
isBound in interface Exchange
Returns:

isBound

public boolean isBound(AMQQueue queue)
Specified by:
isBound in interface Exchange

hasBindings

public boolean hasBindings()
Description copied from interface: Exchange
Returns true if this exchange has at least one binding associated with it.

Specified by:
hasBindings in interface Exchange
Returns:

isBound

public boolean isBound(String bindingKey,
                       AMQQueue queue)
Specified by:
isBound in interface Exchange

isBound

public boolean isBound(String bindingKey)
Specified by:
isBound in interface Exchange

addCloseTask

public void addCloseTask(Exchange.Task task)
Specified by:
addCloseTask in interface Exchange

removeCloseTask

public void removeCloseTask(Exchange.Task task)
Specified by:
removeCloseTask in interface Exchange

getAlternateExchange

public Exchange getAlternateExchange()
Specified by:
getAlternateExchange in interface ExchangeConfig
Specified by:
getAlternateExchange in interface Exchange

getArguments

public Map<String,Object> getArguments()
Specified by:
getArguments in interface ExchangeConfig

setAlternateExchange

public void setAlternateExchange(Exchange exchange)
Specified by:
setAlternateExchange in interface Exchange

removeReference

public void removeReference(ExchangeReferrer exchange)
Specified by:
removeReference in interface Exchange

addReference

public void addReference(ExchangeReferrer exchange)
Specified by:
addReference in interface Exchange

hasReferrers

public boolean hasReferrers()
Specified by:
hasReferrers in interface Exchange

objectCreated

public void objectCreated(QMFObject obj)
Specified by:
objectCreated in interface QMFService.Listener

objectDeleted

public void objectDeleted(QMFObject obj)
Specified by:
objectDeleted in interface QMFService.Listener

getBindingCount

public long getBindingCount()
Specified by:
getBindingCount in interface ExchangeConfig

getBindingCountHigh

public long getBindingCountHigh()
Specified by:
getBindingCountHigh in interface ExchangeConfig

getMsgReceives

public long getMsgReceives()
Specified by:
getMsgReceives in interface ExchangeConfig

getMsgRoutes

public long getMsgRoutes()
Specified by:
getMsgRoutes in interface ExchangeConfig

getByteReceives

public long getByteReceives()
Specified by:
getByteReceives in interface ExchangeConfig

getByteRoutes

public long getByteRoutes()
Specified by:
getByteRoutes in interface ExchangeConfig

getCreateTime

public long getCreateTime()
Specified by:
getCreateTime in interface ConfiguredObject<ExchangeConfigType,ExchangeConfig>

addBindingListener

public void addBindingListener(Exchange.BindingListener listener)
Specified by:
addBindingListener in interface Exchange

removeBindingListener

public void removeBindingListener(Exchange.BindingListener listener)
Specified by:
removeBindingListener in interface Exchange


Licensed to the Apache Software Foundation