org.apache.qpid.server.handler
Class ServerMethodDispatcherImpl

java.lang.Object
  extended by org.apache.qpid.server.handler.ServerMethodDispatcherImpl
All Implemented Interfaces:
org.apache.qpid.framing.ClientMethodDispatcher, org.apache.qpid.framing.MethodDispatcher, org.apache.qpid.framing.ServerMethodDispatcher
Direct Known Subclasses:
ServerMethodDispatcherImpl_0_9, ServerMethodDispatcherImpl_0_91, ServerMethodDispatcherImpl_8_0

public class ServerMethodDispatcherImpl
extends Object
implements org.apache.qpid.framing.MethodDispatcher


Constructor Summary
ServerMethodDispatcherImpl(AMQStateManager stateManager)
           
 
Method Summary
static org.apache.qpid.framing.MethodDispatcher createMethodDispatcher(AMQStateManager stateManager, org.apache.qpid.framing.ProtocolVersion protocolVersion)
           
 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)
           
protected  AMQStateManager getStateManager()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ServerMethodDispatcherImpl

public ServerMethodDispatcherImpl(AMQStateManager stateManager)
Method Detail

createMethodDispatcher

public static org.apache.qpid.framing.MethodDispatcher createMethodDispatcher(AMQStateManager stateManager,
                                                                              org.apache.qpid.framing.ProtocolVersion protocolVersion)

getStateManager

protected AMQStateManager getStateManager()

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

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

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

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

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

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

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

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


Licensed to the Apache Software Foundation