org.apache.qpid.server.exchange
Class FanoutExchange
java.lang.Object
org.apache.qpid.server.exchange.AbstractExchange
org.apache.qpid.server.exchange.FanoutExchange
- All Implemented Interfaces:
- ConfiguredObject<ExchangeConfigType,ExchangeConfig>, ExchangeConfig, Exchange, ExchangeReferrer, Managable
public class FanoutExchange
- extends AbstractExchange
Method Summary |
protected AbstractExchangeMBean |
createMBean()
Concrete exchanges must implement this method in order to create the managed representation. |
ArrayList<BaseQueue> |
doRoute(InboundMessage payload)
|
org.apache.log4j.Logger |
getLogger()
|
boolean |
hasBindings()
Returns true if this exchange has at least one binding associated with it. |
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 |
protected void |
onBind(Binding binding)
|
protected void |
onUnbind(Binding binding)
|
Methods inherited from class org.apache.qpid.server.exchange.AbstractExchange |
addBinding, addBindingListener, addCloseTask, addReference, close, getAlternateExchange, getArguments, getBindingCount, getBindingCountHigh, getBindings, getByteReceives, getByteRoutes, getConfigStore, getConfigType, getCreateTime, getId, getManagedObject, getMsgReceives, getMsgRoutes, getName, getNameShortString, getParent, getQueueRegistry, getTicket, getType, getTypeShortString, getVirtualHost, hasReferrers, initialise, isAutoDelete, isBound, isBound, isBound, isDurable, removeBinding, removeBindingListener, removeCloseTask, removeReference, route, setAlternateExchange, toString |
TYPE
public static final ExchangeType<FanoutExchange> TYPE
FanoutExchange
public FanoutExchange()
createMBean
protected AbstractExchangeMBean createMBean()
throws JMException
- Description copied from class:
AbstractExchange
- Concrete exchanges must implement this method in order to create the managed representation. This is
called during initialisation (template method pattern).
- Specified by:
createMBean
in class AbstractExchange
- Returns:
- the MBean
- Throws:
JMException
getLogger
public org.apache.log4j.Logger getLogger()
- Specified by:
getLogger
in class AbstractExchange
doRoute
public ArrayList<BaseQueue> doRoute(InboundMessage payload)
- Specified by:
doRoute
in class AbstractExchange
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
- 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
- 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
- Returns:
isBound
public boolean isBound(AMQQueue queue)
hasBindings
public boolean hasBindings()
- Description copied from interface:
Exchange
- Returns true if this exchange has at least one binding associated with it.
- Returns:
onBind
protected void onBind(Binding binding)
- Specified by:
onBind
in class AbstractExchange
onUnbind
protected void onUnbind(Binding binding)
- Specified by:
onUnbind
in class AbstractExchange
Licensed to the Apache Software Foundation