|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Exchange
Nested Class Summary | |
---|---|
static interface |
Exchange.BindingListener
|
static interface |
Exchange.Task
|
Method Summary | |
---|---|
void |
addBinding(Binding binding)
|
void |
addBindingListener(Exchange.BindingListener listener)
|
void |
addCloseTask(Exchange.Task task)
|
void |
addReference(ExchangeReferrer exchange)
|
void |
close()
|
Exchange |
getAlternateExchange()
|
Collection<Binding> |
getBindings()
|
org.apache.qpid.framing.AMQShortString |
getNameShortString()
|
int |
getTicket()
|
org.apache.qpid.framing.AMQShortString |
getTypeShortString()
|
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 |
removeBinding(Binding binding)
|
void |
removeBindingListener(Exchange.BindingListener listener)
|
void |
removeCloseTask(Exchange.Task task)
|
void |
removeReference(ExchangeReferrer exchange)
|
ArrayList<? extends BaseQueue> |
route(InboundMessage message)
|
void |
setAlternateExchange(Exchange exchange)
|
Methods inherited from interface org.apache.qpid.server.configuration.ExchangeConfig |
---|
getArguments, getBindingCount, getBindingCountHigh, getByteReceives, getByteRoutes, getMsgReceives, getMsgRoutes, getName, getType, getVirtualHost |
Methods inherited from interface org.apache.qpid.server.configuration.ConfiguredObject |
---|
getConfigType, getCreateTime, getId, getParent |
Method Detail |
---|
org.apache.qpid.framing.AMQShortString getNameShortString()
org.apache.qpid.framing.AMQShortString getTypeShortString()
void initialise(VirtualHost host, org.apache.qpid.framing.AMQShortString name, boolean durable, int ticket, boolean autoDelete) throws org.apache.qpid.AMQException, JMException
org.apache.qpid.AMQException
JMException
boolean isDurable()
isDurable
in interface ConfiguredObject<ExchangeConfigType,ExchangeConfig>
boolean isAutoDelete()
isAutoDelete
in interface ExchangeConfig
int getTicket()
void close() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
ArrayList<? extends BaseQueue> route(InboundMessage message)
boolean isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.FieldTable arguments, AMQQueue queue)
routingKey
- arguments
- queue
-
org.apache.qpid.AMQException
boolean isBound(org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue)
routingKey
- queue
-
org.apache.qpid.AMQException
boolean isBound(org.apache.qpid.framing.AMQShortString routingKey)
routingKey
-
org.apache.qpid.AMQException
boolean isBound(AMQQueue queue)
boolean hasBindings()
org.apache.qpid.AMQException
boolean isBound(String bindingKey, AMQQueue queue)
boolean isBound(String bindingKey)
void addCloseTask(Exchange.Task task)
void removeCloseTask(Exchange.Task task)
Exchange getAlternateExchange()
getAlternateExchange
in interface ExchangeConfig
void setAlternateExchange(Exchange exchange)
void removeReference(ExchangeReferrer exchange)
void addReference(ExchangeReferrer exchange)
boolean hasReferrers()
void addBinding(Binding binding)
void removeBinding(Binding binding)
Collection<Binding> getBindings()
void addBindingListener(Exchange.BindingListener listener)
void removeBindingListener(Exchange.BindingListener listener)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |