org.apache.qpid.framing
Interface ServerMethodDispatcher
- All Known Subinterfaces:
- MethodDispatcher, MethodDispatcher_0_9, MethodDispatcher_0_91, MethodDispatcher_8_0, ServerMethodDispatcher_0_9, ServerMethodDispatcher_0_91, ServerMethodDispatcher_8_0
public interface ServerMethodDispatcher
Method Summary |
boolean |
dispatchBasicAck(BasicAckBody body,
int channelId)
|
boolean |
dispatchBasicCancel(BasicCancelBody body,
int channelId)
|
boolean |
dispatchBasicConsume(BasicConsumeBody body,
int channelId)
|
boolean |
dispatchBasicGet(BasicGetBody body,
int channelId)
|
boolean |
dispatchBasicPublish(BasicPublishBody body,
int channelId)
|
boolean |
dispatchBasicQos(BasicQosBody body,
int channelId)
|
boolean |
dispatchBasicRecover(BasicRecoverBody body,
int channelId)
|
boolean |
dispatchBasicReject(BasicRejectBody body,
int channelId)
|
boolean |
dispatchChannelClose(ChannelCloseBody body,
int channelId)
|
boolean |
dispatchChannelCloseOk(ChannelCloseOkBody body,
int channelId)
|
boolean |
dispatchChannelFlow(ChannelFlowBody body,
int channelId)
|
boolean |
dispatchChannelFlowOk(ChannelFlowOkBody body,
int channelId)
|
boolean |
dispatchChannelOpen(ChannelOpenBody body,
int channelId)
|
boolean |
dispatchConnectionClose(ConnectionCloseBody body,
int channelId)
|
boolean |
dispatchConnectionCloseOk(ConnectionCloseOkBody body,
int channelId)
|
boolean |
dispatchConnectionOpen(ConnectionOpenBody body,
int channelId)
|
boolean |
dispatchConnectionSecureOk(ConnectionSecureOkBody body,
int channelId)
|
boolean |
dispatchConnectionStartOk(ConnectionStartOkBody body,
int channelId)
|
boolean |
dispatchConnectionTuneOk(ConnectionTuneOkBody body,
int channelId)
|
boolean |
dispatchExchangeBound(ExchangeBoundBody body,
int channelId)
|
boolean |
dispatchExchangeDeclare(ExchangeDeclareBody body,
int channelId)
|
boolean |
dispatchExchangeDelete(ExchangeDeleteBody body,
int channelId)
|
boolean |
dispatchQueueBind(QueueBindBody body,
int channelId)
|
boolean |
dispatchQueueDeclare(QueueDeclareBody body,
int channelId)
|
boolean |
dispatchQueueDelete(QueueDeleteBody body,
int channelId)
|
boolean |
dispatchQueuePurge(QueuePurgeBody body,
int channelId)
|
boolean |
dispatchTxCommit(TxCommitBody body,
int channelId)
|
boolean |
dispatchTxRollback(TxRollbackBody body,
int channelId)
|
boolean |
dispatchTxSelect(TxSelectBody body,
int channelId)
|
dispatchBasicAck
boolean dispatchBasicAck(BasicAckBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchBasicCancel
boolean dispatchBasicCancel(BasicCancelBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchBasicConsume
boolean dispatchBasicConsume(BasicConsumeBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchBasicGet
boolean dispatchBasicGet(BasicGetBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchBasicPublish
boolean dispatchBasicPublish(BasicPublishBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchBasicQos
boolean dispatchBasicQos(BasicQosBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchBasicRecover
boolean dispatchBasicRecover(BasicRecoverBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchBasicReject
boolean dispatchBasicReject(BasicRejectBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchChannelClose
boolean dispatchChannelClose(ChannelCloseBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchChannelCloseOk
boolean dispatchChannelCloseOk(ChannelCloseOkBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchChannelFlow
boolean dispatchChannelFlow(ChannelFlowBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchChannelFlowOk
boolean dispatchChannelFlowOk(ChannelFlowOkBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchChannelOpen
boolean dispatchChannelOpen(ChannelOpenBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchConnectionClose
boolean dispatchConnectionClose(ConnectionCloseBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchConnectionCloseOk
boolean dispatchConnectionCloseOk(ConnectionCloseOkBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchConnectionOpen
boolean dispatchConnectionOpen(ConnectionOpenBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchConnectionSecureOk
boolean dispatchConnectionSecureOk(ConnectionSecureOkBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchConnectionStartOk
boolean dispatchConnectionStartOk(ConnectionStartOkBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchConnectionTuneOk
boolean dispatchConnectionTuneOk(ConnectionTuneOkBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchExchangeBound
boolean dispatchExchangeBound(ExchangeBoundBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchExchangeDeclare
boolean dispatchExchangeDeclare(ExchangeDeclareBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchExchangeDelete
boolean dispatchExchangeDelete(ExchangeDeleteBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchQueueBind
boolean dispatchQueueBind(QueueBindBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchQueueDeclare
boolean dispatchQueueDeclare(QueueDeclareBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchQueueDelete
boolean dispatchQueueDelete(QueueDeleteBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchQueuePurge
boolean dispatchQueuePurge(QueuePurgeBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchTxCommit
boolean dispatchTxCommit(TxCommitBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchTxRollback
boolean dispatchTxRollback(TxRollbackBody body,
int channelId)
throws AMQException
- Throws:
AMQException
dispatchTxSelect
boolean dispatchTxSelect(TxSelectBody body,
int channelId)
throws AMQException
- Throws:
AMQException
Licensed to the Apache Software Foundation