org.apache.qpid.qmf
Class ManagementExchange
java.lang.Object
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
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 |
TYPE
public static final ExchangeType<ManagementExchange> TYPE
ManagementExchange
public ManagementExchange()
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