org.apache.qpid.client.handler
Class ClientMethodDispatcherImpl
java.lang.Object
org.apache.qpid.client.handler.ClientMethodDispatcherImpl
- All Implemented Interfaces:
- org.apache.qpid.framing.ClientMethodDispatcher, org.apache.qpid.framing.MethodDispatcher, org.apache.qpid.framing.ServerMethodDispatcher
- Direct Known Subclasses:
- ClientMethodDispatcherImpl_0_9, ClientMethodDispatcherImpl_0_91, ClientMethodDispatcherImpl_8_0
public class ClientMethodDispatcherImpl
- extends Object
- implements org.apache.qpid.framing.MethodDispatcher
Method Summary |
boolean |
dispatchAccessRequest(org.apache.qpid.framing.AccessRequestBody body,
int channelId)
|
boolean |
dispatchAccessRequestOk(org.apache.qpid.framing.AccessRequestOkBody body,
int channelId)
|
boolean |
dispatchBasicAck(org.apache.qpid.framing.BasicAckBody body,
int channelId)
|
boolean |
dispatchBasicCancel(org.apache.qpid.framing.BasicCancelBody body,
int channelId)
|
boolean |
dispatchBasicCancelOk(org.apache.qpid.framing.BasicCancelOkBody body,
int channelId)
|
boolean |
dispatchBasicConsume(org.apache.qpid.framing.BasicConsumeBody body,
int channelId)
|
boolean |
dispatchBasicConsumeOk(org.apache.qpid.framing.BasicConsumeOkBody body,
int channelId)
|
boolean |
dispatchBasicDeliver(org.apache.qpid.framing.BasicDeliverBody body,
int channelId)
|
boolean |
dispatchBasicGet(org.apache.qpid.framing.BasicGetBody body,
int channelId)
|
boolean |
dispatchBasicGetEmpty(org.apache.qpid.framing.BasicGetEmptyBody body,
int channelId)
|
boolean |
dispatchBasicGetOk(org.apache.qpid.framing.BasicGetOkBody body,
int channelId)
|
boolean |
dispatchBasicPublish(org.apache.qpid.framing.BasicPublishBody body,
int channelId)
|
boolean |
dispatchBasicQos(org.apache.qpid.framing.BasicQosBody body,
int channelId)
|
boolean |
dispatchBasicQosOk(org.apache.qpid.framing.BasicQosOkBody body,
int channelId)
|
boolean |
dispatchBasicRecover(org.apache.qpid.framing.BasicRecoverBody body,
int channelId)
|
boolean |
dispatchBasicReject(org.apache.qpid.framing.BasicRejectBody body,
int channelId)
|
boolean |
dispatchBasicReturn(org.apache.qpid.framing.BasicReturnBody body,
int channelId)
|
boolean |
dispatchChannelClose(org.apache.qpid.framing.ChannelCloseBody body,
int channelId)
|
boolean |
dispatchChannelCloseOk(org.apache.qpid.framing.ChannelCloseOkBody body,
int channelId)
|
boolean |
dispatchChannelFlow(org.apache.qpid.framing.ChannelFlowBody body,
int channelId)
|
boolean |
dispatchChannelFlowOk(org.apache.qpid.framing.ChannelFlowOkBody body,
int channelId)
|
boolean |
dispatchChannelOpen(org.apache.qpid.framing.ChannelOpenBody body,
int channelId)
|
boolean |
dispatchChannelOpenOk(org.apache.qpid.framing.ChannelOpenOkBody body,
int channelId)
|
boolean |
dispatchConnectionClose(org.apache.qpid.framing.ConnectionCloseBody body,
int channelId)
|
boolean |
dispatchConnectionCloseOk(org.apache.qpid.framing.ConnectionCloseOkBody body,
int channelId)
|
boolean |
dispatchConnectionOpen(org.apache.qpid.framing.ConnectionOpenBody body,
int channelId)
|
boolean |
dispatchConnectionOpenOk(org.apache.qpid.framing.ConnectionOpenOkBody body,
int channelId)
|
boolean |
dispatchConnectionRedirect(org.apache.qpid.framing.ConnectionRedirectBody body,
int channelId)
|
boolean |
dispatchConnectionSecure(org.apache.qpid.framing.ConnectionSecureBody body,
int channelId)
|
boolean |
dispatchConnectionSecureOk(org.apache.qpid.framing.ConnectionSecureOkBody body,
int channelId)
|
boolean |
dispatchConnectionStart(org.apache.qpid.framing.ConnectionStartBody body,
int channelId)
|
boolean |
dispatchConnectionStartOk(org.apache.qpid.framing.ConnectionStartOkBody body,
int channelId)
|
boolean |
dispatchConnectionTune(org.apache.qpid.framing.ConnectionTuneBody body,
int channelId)
|
boolean |
dispatchConnectionTuneOk(org.apache.qpid.framing.ConnectionTuneOkBody body,
int channelId)
|
boolean |
dispatchDtxSelect(org.apache.qpid.framing.DtxSelectBody body,
int channelId)
|
boolean |
dispatchDtxSelectOk(org.apache.qpid.framing.DtxSelectOkBody body,
int channelId)
|
boolean |
dispatchDtxStart(org.apache.qpid.framing.DtxStartBody body,
int channelId)
|
boolean |
dispatchDtxStartOk(org.apache.qpid.framing.DtxStartOkBody body,
int channelId)
|
boolean |
dispatchExchangeBound(org.apache.qpid.framing.ExchangeBoundBody body,
int channelId)
|
boolean |
dispatchExchangeBoundOk(org.apache.qpid.framing.ExchangeBoundOkBody body,
int channelId)
|
boolean |
dispatchExchangeDeclare(org.apache.qpid.framing.ExchangeDeclareBody body,
int channelId)
|
boolean |
dispatchExchangeDeclareOk(org.apache.qpid.framing.ExchangeDeclareOkBody body,
int channelId)
|
boolean |
dispatchExchangeDelete(org.apache.qpid.framing.ExchangeDeleteBody body,
int channelId)
|
boolean |
dispatchExchangeDeleteOk(org.apache.qpid.framing.ExchangeDeleteOkBody body,
int channelId)
|
boolean |
dispatchFileAck(org.apache.qpid.framing.FileAckBody body,
int channelId)
|
boolean |
dispatchFileCancel(org.apache.qpid.framing.FileCancelBody body,
int channelId)
|
boolean |
dispatchFileCancelOk(org.apache.qpid.framing.FileCancelOkBody body,
int channelId)
|
boolean |
dispatchFileConsume(org.apache.qpid.framing.FileConsumeBody body,
int channelId)
|
boolean |
dispatchFileConsumeOk(org.apache.qpid.framing.FileConsumeOkBody body,
int channelId)
|
boolean |
dispatchFileDeliver(org.apache.qpid.framing.FileDeliverBody body,
int channelId)
|
boolean |
dispatchFileOpen(org.apache.qpid.framing.FileOpenBody body,
int channelId)
|
boolean |
dispatchFileOpenOk(org.apache.qpid.framing.FileOpenOkBody body,
int channelId)
|
boolean |
dispatchFilePublish(org.apache.qpid.framing.FilePublishBody body,
int channelId)
|
boolean |
dispatchFileQos(org.apache.qpid.framing.FileQosBody body,
int channelId)
|
boolean |
dispatchFileQosOk(org.apache.qpid.framing.FileQosOkBody body,
int channelId)
|
boolean |
dispatchFileReject(org.apache.qpid.framing.FileRejectBody body,
int channelId)
|
boolean |
dispatchFileReturn(org.apache.qpid.framing.FileReturnBody body,
int channelId)
|
boolean |
dispatchFileStage(org.apache.qpid.framing.FileStageBody body,
int channelId)
|
boolean |
dispatchQueueBind(org.apache.qpid.framing.QueueBindBody body,
int channelId)
|
boolean |
dispatchQueueBindOk(org.apache.qpid.framing.QueueBindOkBody body,
int channelId)
|
boolean |
dispatchQueueDeclare(org.apache.qpid.framing.QueueDeclareBody body,
int channelId)
|
boolean |
dispatchQueueDeclareOk(org.apache.qpid.framing.QueueDeclareOkBody body,
int channelId)
|
boolean |
dispatchQueueDelete(org.apache.qpid.framing.QueueDeleteBody body,
int channelId)
|
boolean |
dispatchQueueDeleteOk(org.apache.qpid.framing.QueueDeleteOkBody body,
int channelId)
|
boolean |
dispatchQueuePurge(org.apache.qpid.framing.QueuePurgeBody body,
int channelId)
|
boolean |
dispatchQueuePurgeOk(org.apache.qpid.framing.QueuePurgeOkBody body,
int channelId)
|
boolean |
dispatchStreamCancel(org.apache.qpid.framing.StreamCancelBody body,
int channelId)
|
boolean |
dispatchStreamCancelOk(org.apache.qpid.framing.StreamCancelOkBody body,
int channelId)
|
boolean |
dispatchStreamConsume(org.apache.qpid.framing.StreamConsumeBody body,
int channelId)
|
boolean |
dispatchStreamConsumeOk(org.apache.qpid.framing.StreamConsumeOkBody body,
int channelId)
|
boolean |
dispatchStreamDeliver(org.apache.qpid.framing.StreamDeliverBody body,
int channelId)
|
boolean |
dispatchStreamPublish(org.apache.qpid.framing.StreamPublishBody body,
int channelId)
|
boolean |
dispatchStreamQos(org.apache.qpid.framing.StreamQosBody body,
int channelId)
|
boolean |
dispatchStreamQosOk(org.apache.qpid.framing.StreamQosOkBody body,
int channelId)
|
boolean |
dispatchStreamReturn(org.apache.qpid.framing.StreamReturnBody body,
int channelId)
|
boolean |
dispatchTunnelRequest(org.apache.qpid.framing.TunnelRequestBody body,
int channelId)
|
boolean |
dispatchTxCommit(org.apache.qpid.framing.TxCommitBody body,
int channelId)
|
boolean |
dispatchTxCommitOk(org.apache.qpid.framing.TxCommitOkBody body,
int channelId)
|
boolean |
dispatchTxRollback(org.apache.qpid.framing.TxRollbackBody body,
int channelId)
|
boolean |
dispatchTxRollbackOk(org.apache.qpid.framing.TxRollbackOkBody body,
int channelId)
|
boolean |
dispatchTxSelect(org.apache.qpid.framing.TxSelectBody body,
int channelId)
|
boolean |
dispatchTxSelectOk(org.apache.qpid.framing.TxSelectOkBody body,
int channelId)
|
AMQStateManager |
getStateManager()
|
static ClientMethodDispatcherImpl |
newMethodDispatcher(org.apache.qpid.framing.ProtocolVersion version,
AMQProtocolSession session)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_session
AMQProtocolSession _session
ClientMethodDispatcherImpl
public ClientMethodDispatcherImpl(AMQProtocolSession session)
newMethodDispatcher
public static ClientMethodDispatcherImpl newMethodDispatcher(org.apache.qpid.framing.ProtocolVersion version,
AMQProtocolSession session)
getStateManager
public AMQStateManager getStateManager()
dispatchAccessRequestOk
public boolean dispatchAccessRequestOk(org.apache.qpid.framing.AccessRequestOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchBasicCancelOk
public boolean dispatchBasicCancelOk(org.apache.qpid.framing.BasicCancelOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicCancelOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicConsumeOk
public boolean dispatchBasicConsumeOk(org.apache.qpid.framing.BasicConsumeOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicConsumeOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicDeliver
public boolean dispatchBasicDeliver(org.apache.qpid.framing.BasicDeliverBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicDeliver
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicGetEmpty
public boolean dispatchBasicGetEmpty(org.apache.qpid.framing.BasicGetEmptyBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicGetEmpty
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicGetOk
public boolean dispatchBasicGetOk(org.apache.qpid.framing.BasicGetOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicGetOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicQosOk
public boolean dispatchBasicQosOk(org.apache.qpid.framing.BasicQosOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicQosOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicReturn
public boolean dispatchBasicReturn(org.apache.qpid.framing.BasicReturnBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicReturn
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchChannelClose
public boolean dispatchChannelClose(org.apache.qpid.framing.ChannelCloseBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchChannelClose
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Specified by:
dispatchChannelClose
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchChannelCloseOk
public boolean dispatchChannelCloseOk(org.apache.qpid.framing.ChannelCloseOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchChannelCloseOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Specified by:
dispatchChannelCloseOk
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchChannelFlow
public boolean dispatchChannelFlow(org.apache.qpid.framing.ChannelFlowBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchChannelFlow
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Specified by:
dispatchChannelFlow
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchChannelFlowOk
public boolean dispatchChannelFlowOk(org.apache.qpid.framing.ChannelFlowOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchChannelFlowOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Specified by:
dispatchChannelFlowOk
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchChannelOpenOk
public boolean dispatchChannelOpenOk(org.apache.qpid.framing.ChannelOpenOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchChannelOpenOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionClose
public boolean dispatchConnectionClose(org.apache.qpid.framing.ConnectionCloseBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionClose
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Specified by:
dispatchConnectionClose
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionCloseOk
public boolean dispatchConnectionCloseOk(org.apache.qpid.framing.ConnectionCloseOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionCloseOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Specified by:
dispatchConnectionCloseOk
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionOpenOk
public boolean dispatchConnectionOpenOk(org.apache.qpid.framing.ConnectionOpenOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionOpenOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionRedirect
public boolean dispatchConnectionRedirect(org.apache.qpid.framing.ConnectionRedirectBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchConnectionSecure
public boolean dispatchConnectionSecure(org.apache.qpid.framing.ConnectionSecureBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionSecure
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionStart
public boolean dispatchConnectionStart(org.apache.qpid.framing.ConnectionStartBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionStart
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionTune
public boolean dispatchConnectionTune(org.apache.qpid.framing.ConnectionTuneBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionTune
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchQueueDeleteOk
public boolean dispatchQueueDeleteOk(org.apache.qpid.framing.QueueDeleteOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchQueueDeleteOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchQueuePurgeOk
public boolean dispatchQueuePurgeOk(org.apache.qpid.framing.QueuePurgeOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchQueuePurgeOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchStreamCancelOk
public boolean dispatchStreamCancelOk(org.apache.qpid.framing.StreamCancelOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchStreamConsumeOk
public boolean dispatchStreamConsumeOk(org.apache.qpid.framing.StreamConsumeOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchAccessRequest
public boolean dispatchAccessRequest(org.apache.qpid.framing.AccessRequestBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchBasicAck
public boolean dispatchBasicAck(org.apache.qpid.framing.BasicAckBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicAck
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicCancel
public boolean dispatchBasicCancel(org.apache.qpid.framing.BasicCancelBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicCancel
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicConsume
public boolean dispatchBasicConsume(org.apache.qpid.framing.BasicConsumeBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicConsume
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicGet
public boolean dispatchBasicGet(org.apache.qpid.framing.BasicGetBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicGet
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicPublish
public boolean dispatchBasicPublish(org.apache.qpid.framing.BasicPublishBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicPublish
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicQos
public boolean dispatchBasicQos(org.apache.qpid.framing.BasicQosBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicQos
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicRecover
public boolean dispatchBasicRecover(org.apache.qpid.framing.BasicRecoverBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicRecover
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchBasicReject
public boolean dispatchBasicReject(org.apache.qpid.framing.BasicRejectBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchBasicReject
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchChannelOpen
public boolean dispatchChannelOpen(org.apache.qpid.framing.ChannelOpenBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchChannelOpen
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionOpen
public boolean dispatchConnectionOpen(org.apache.qpid.framing.ConnectionOpenBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionOpen
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionSecureOk
public boolean dispatchConnectionSecureOk(org.apache.qpid.framing.ConnectionSecureOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionSecureOk
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionStartOk
public boolean dispatchConnectionStartOk(org.apache.qpid.framing.ConnectionStartOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionStartOk
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchConnectionTuneOk
public boolean dispatchConnectionTuneOk(org.apache.qpid.framing.ConnectionTuneOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchConnectionTuneOk
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchDtxSelect
public boolean dispatchDtxSelect(org.apache.qpid.framing.DtxSelectBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchDtxStart
public boolean dispatchDtxStart(org.apache.qpid.framing.DtxStartBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchExchangeBound
public boolean dispatchExchangeBound(org.apache.qpid.framing.ExchangeBoundBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchExchangeBound
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchExchangeDeclare
public boolean dispatchExchangeDeclare(org.apache.qpid.framing.ExchangeDeclareBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchExchangeDeclare
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchExchangeDelete
public boolean dispatchExchangeDelete(org.apache.qpid.framing.ExchangeDeleteBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchExchangeDelete
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchFileAck
public boolean dispatchFileAck(org.apache.qpid.framing.FileAckBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileCancel
public boolean dispatchFileCancel(org.apache.qpid.framing.FileCancelBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileConsume
public boolean dispatchFileConsume(org.apache.qpid.framing.FileConsumeBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFilePublish
public boolean dispatchFilePublish(org.apache.qpid.framing.FilePublishBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileQos
public boolean dispatchFileQos(org.apache.qpid.framing.FileQosBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileReject
public boolean dispatchFileReject(org.apache.qpid.framing.FileRejectBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchQueueBind
public boolean dispatchQueueBind(org.apache.qpid.framing.QueueBindBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchQueueBind
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchQueueDeclare
public boolean dispatchQueueDeclare(org.apache.qpid.framing.QueueDeclareBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchQueueDeclare
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchQueueDelete
public boolean dispatchQueueDelete(org.apache.qpid.framing.QueueDeleteBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchQueueDelete
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchQueuePurge
public boolean dispatchQueuePurge(org.apache.qpid.framing.QueuePurgeBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchQueuePurge
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchStreamCancel
public boolean dispatchStreamCancel(org.apache.qpid.framing.StreamCancelBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchStreamConsume
public boolean dispatchStreamConsume(org.apache.qpid.framing.StreamConsumeBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchStreamPublish
public boolean dispatchStreamPublish(org.apache.qpid.framing.StreamPublishBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchStreamQos
public boolean dispatchStreamQos(org.apache.qpid.framing.StreamQosBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchTunnelRequest
public boolean dispatchTunnelRequest(org.apache.qpid.framing.TunnelRequestBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchTxCommit
public boolean dispatchTxCommit(org.apache.qpid.framing.TxCommitBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchTxCommit
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchTxRollback
public boolean dispatchTxRollback(org.apache.qpid.framing.TxRollbackBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchTxRollback
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchTxSelect
public boolean dispatchTxSelect(org.apache.qpid.framing.TxSelectBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchTxSelect
in interface org.apache.qpid.framing.ServerMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchDtxSelectOk
public boolean dispatchDtxSelectOk(org.apache.qpid.framing.DtxSelectOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchDtxStartOk
public boolean dispatchDtxStartOk(org.apache.qpid.framing.DtxStartOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchExchangeBoundOk
public boolean dispatchExchangeBoundOk(org.apache.qpid.framing.ExchangeBoundOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchExchangeBoundOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchExchangeDeclareOk
public boolean dispatchExchangeDeclareOk(org.apache.qpid.framing.ExchangeDeclareOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchExchangeDeclareOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchExchangeDeleteOk
public boolean dispatchExchangeDeleteOk(org.apache.qpid.framing.ExchangeDeleteOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchExchangeDeleteOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchFileCancelOk
public boolean dispatchFileCancelOk(org.apache.qpid.framing.FileCancelOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileConsumeOk
public boolean dispatchFileConsumeOk(org.apache.qpid.framing.FileConsumeOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileDeliver
public boolean dispatchFileDeliver(org.apache.qpid.framing.FileDeliverBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileOpen
public boolean dispatchFileOpen(org.apache.qpid.framing.FileOpenBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileOpenOk
public boolean dispatchFileOpenOk(org.apache.qpid.framing.FileOpenOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileQosOk
public boolean dispatchFileQosOk(org.apache.qpid.framing.FileQosOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileReturn
public boolean dispatchFileReturn(org.apache.qpid.framing.FileReturnBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchFileStage
public boolean dispatchFileStage(org.apache.qpid.framing.FileStageBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchQueueBindOk
public boolean dispatchQueueBindOk(org.apache.qpid.framing.QueueBindOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchQueueBindOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchQueueDeclareOk
public boolean dispatchQueueDeclareOk(org.apache.qpid.framing.QueueDeclareOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchQueueDeclareOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchStreamDeliver
public boolean dispatchStreamDeliver(org.apache.qpid.framing.StreamDeliverBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchStreamQosOk
public boolean dispatchStreamQosOk(org.apache.qpid.framing.StreamQosOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchStreamReturn
public boolean dispatchStreamReturn(org.apache.qpid.framing.StreamReturnBody body,
int channelId)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
dispatchTxCommitOk
public boolean dispatchTxCommitOk(org.apache.qpid.framing.TxCommitOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchTxCommitOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchTxRollbackOk
public boolean dispatchTxRollbackOk(org.apache.qpid.framing.TxRollbackOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchTxRollbackOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
dispatchTxSelectOk
public boolean dispatchTxSelectOk(org.apache.qpid.framing.TxSelectOkBody body,
int channelId)
throws org.apache.qpid.AMQException
- Specified by:
dispatchTxSelectOk
in interface org.apache.qpid.framing.ClientMethodDispatcher
- Throws:
org.apache.qpid.AMQException
Licensed to the Apache Software Foundation