org.apache.qpid.client.handler
Class ClientMethodDispatcherImpl

java.lang.Object
  extended by 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


Field Summary
(package private)  AMQProtocolSession _session
           
 
Constructor Summary
ClientMethodDispatcherImpl(AMQProtocolSession session)
           
 
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
 

Field Detail

_session

AMQProtocolSession _session
Constructor Detail

ClientMethodDispatcherImpl

public ClientMethodDispatcherImpl(AMQProtocolSession session)
Method Detail

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