org.apache.qpid.server.handler
Class ServerMethodDispatcherImpl_0_91

java.lang.Object
  extended by org.apache.qpid.server.handler.ServerMethodDispatcherImpl
      extended by org.apache.qpid.server.handler.ServerMethodDispatcherImpl_0_91
All Implemented Interfaces:
org.apache.qpid.framing.amqp_0_91.ClientMethodDispatcher_0_91, org.apache.qpid.framing.amqp_0_91.MethodDispatcher_0_91, org.apache.qpid.framing.amqp_0_91.ServerMethodDispatcher_0_91, org.apache.qpid.framing.ClientMethodDispatcher, org.apache.qpid.framing.MethodDispatcher, org.apache.qpid.framing.ServerMethodDispatcher

public class ServerMethodDispatcherImpl_0_91
extends ServerMethodDispatcherImpl
implements org.apache.qpid.framing.amqp_0_91.MethodDispatcher_0_91


Constructor Summary
ServerMethodDispatcherImpl_0_91(AMQStateManager stateManager)
           
 
Method Summary
 boolean dispatchBasicRecoverOk(org.apache.qpid.framing.BasicRecoverOkBody body, int channelId)
           
 boolean dispatchBasicRecoverSync(org.apache.qpid.framing.BasicRecoverSyncBody body, int channelId)
           
 boolean dispatchBasicRecoverSyncOk(org.apache.qpid.framing.BasicRecoverSyncOkBody body, int channelId)
           
 boolean dispatchChannelOk(org.apache.qpid.framing.ChannelOkBody body, int channelId)
           
 boolean dispatchChannelPing(org.apache.qpid.framing.ChannelPingBody body, int channelId)
           
 boolean dispatchChannelPong(org.apache.qpid.framing.ChannelPongBody body, int channelId)
           
 boolean dispatchChannelResume(org.apache.qpid.framing.ChannelResumeBody body, int channelId)
           
 boolean dispatchMessageAppend(org.apache.qpid.framing.MessageAppendBody body, int channelId)
           
 boolean dispatchMessageCancel(org.apache.qpid.framing.MessageCancelBody body, int channelId)
           
 boolean dispatchMessageCheckpoint(org.apache.qpid.framing.MessageCheckpointBody body, int channelId)
           
 boolean dispatchMessageClose(org.apache.qpid.framing.MessageCloseBody body, int channelId)
           
 boolean dispatchMessageConsume(org.apache.qpid.framing.MessageConsumeBody body, int channelId)
           
 boolean dispatchMessageEmpty(org.apache.qpid.framing.MessageEmptyBody body, int channelId)
           
 boolean dispatchMessageGet(org.apache.qpid.framing.MessageGetBody body, int channelId)
           
 boolean dispatchMessageOffset(org.apache.qpid.framing.MessageOffsetBody body, int channelId)
           
 boolean dispatchMessageOk(org.apache.qpid.framing.MessageOkBody body, int channelId)
           
 boolean dispatchMessageOpen(org.apache.qpid.framing.MessageOpenBody body, int channelId)
           
 boolean dispatchMessageQos(org.apache.qpid.framing.MessageQosBody body, int channelId)
           
 boolean dispatchMessageRecover(org.apache.qpid.framing.MessageRecoverBody body, int channelId)
           
 boolean dispatchMessageReject(org.apache.qpid.framing.MessageRejectBody body, int channelId)
           
 boolean dispatchMessageResume(org.apache.qpid.framing.MessageResumeBody body, int channelId)
           
 boolean dispatchMessageTransfer(org.apache.qpid.framing.MessageTransferBody body, int channelId)
           
 boolean dispatchQueueUnbind(org.apache.qpid.framing.QueueUnbindBody body, int channelId)
           
 boolean dispatchQueueUnbindOk(org.apache.qpid.framing.QueueUnbindOkBody body, int channelId)
           
 
Methods inherited from class org.apache.qpid.server.handler.ServerMethodDispatcherImpl
createMethodDispatcher, dispatchAccessRequest, dispatchAccessRequestOk, dispatchBasicAck, dispatchBasicCancel, dispatchBasicCancelOk, dispatchBasicConsume, dispatchBasicConsumeOk, dispatchBasicDeliver, dispatchBasicGet, dispatchBasicGetEmpty, dispatchBasicGetOk, dispatchBasicPublish, dispatchBasicQos, dispatchBasicQosOk, dispatchBasicRecover, dispatchBasicReject, dispatchBasicReturn, dispatchChannelClose, dispatchChannelCloseOk, dispatchChannelFlow, dispatchChannelFlowOk, dispatchChannelOpen, dispatchChannelOpenOk, dispatchConnectionClose, dispatchConnectionCloseOk, dispatchConnectionOpen, dispatchConnectionOpenOk, dispatchConnectionRedirect, dispatchConnectionSecure, dispatchConnectionSecureOk, dispatchConnectionStart, dispatchConnectionStartOk, dispatchConnectionTune, dispatchConnectionTuneOk, dispatchDtxSelect, dispatchDtxSelectOk, dispatchDtxStart, dispatchDtxStartOk, dispatchExchangeBound, dispatchExchangeBoundOk, dispatchExchangeDeclare, dispatchExchangeDeclareOk, dispatchExchangeDelete, dispatchExchangeDeleteOk, dispatchFileAck, dispatchFileCancel, dispatchFileCancelOk, dispatchFileConsume, dispatchFileConsumeOk, dispatchFileDeliver, dispatchFileOpen, dispatchFileOpenOk, dispatchFilePublish, dispatchFileQos, dispatchFileQosOk, dispatchFileReject, dispatchFileReturn, dispatchFileStage, dispatchQueueBind, dispatchQueueBindOk, dispatchQueueDeclare, dispatchQueueDeclareOk, dispatchQueueDelete, dispatchQueueDeleteOk, dispatchQueuePurge, dispatchQueuePurgeOk, dispatchStreamCancel, dispatchStreamCancelOk, dispatchStreamConsume, dispatchStreamConsumeOk, dispatchStreamDeliver, dispatchStreamPublish, dispatchStreamQos, dispatchStreamQosOk, dispatchStreamReturn, dispatchTunnelRequest, dispatchTxCommit, dispatchTxCommitOk, dispatchTxRollback, dispatchTxRollbackOk, dispatchTxSelect, dispatchTxSelectOk, getStateManager
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.qpid.framing.amqp_0_91.ServerMethodDispatcher_0_91
dispatchBasicAck, dispatchBasicCancel, dispatchBasicConsume, dispatchBasicGet, dispatchBasicPublish, dispatchBasicQos, dispatchBasicRecover, dispatchBasicReject, dispatchChannelClose, dispatchChannelCloseOk, dispatchChannelFlow, dispatchChannelFlowOk, dispatchChannelOpen, dispatchConnectionClose, dispatchConnectionCloseOk, dispatchConnectionOpen, dispatchConnectionSecureOk, dispatchConnectionStartOk, dispatchConnectionTuneOk, dispatchExchangeBound, dispatchExchangeDeclare, dispatchExchangeDelete, dispatchQueueBind, dispatchQueueDeclare, dispatchQueueDelete, dispatchQueuePurge, dispatchTxCommit, dispatchTxRollback, dispatchTxSelect
 
Methods inherited from interface org.apache.qpid.framing.amqp_0_91.ClientMethodDispatcher_0_91
dispatchBasicCancelOk, dispatchBasicConsumeOk, dispatchBasicDeliver, dispatchBasicGetEmpty, dispatchBasicGetOk, dispatchBasicQosOk, dispatchBasicReturn, dispatchChannelClose, dispatchChannelCloseOk, dispatchChannelFlow, dispatchChannelFlowOk, dispatchChannelOpenOk, dispatchConnectionClose, dispatchConnectionCloseOk, dispatchConnectionOpenOk, dispatchConnectionSecure, dispatchConnectionStart, dispatchConnectionTune, dispatchExchangeBoundOk, dispatchExchangeDeclareOk, dispatchExchangeDeleteOk, dispatchQueueBindOk, dispatchQueueDeclareOk, dispatchQueueDeleteOk, dispatchQueuePurgeOk, dispatchTxCommitOk, dispatchTxRollbackOk, dispatchTxSelectOk
 

Constructor Detail

ServerMethodDispatcherImpl_0_91

public ServerMethodDispatcherImpl_0_91(AMQStateManager stateManager)
Method Detail

dispatchBasicRecoverSync

public boolean dispatchBasicRecoverSync(org.apache.qpid.framing.BasicRecoverSyncBody body,
                                        int channelId)
                                 throws org.apache.qpid.AMQException
Specified by:
dispatchBasicRecoverSync in interface org.apache.qpid.framing.amqp_0_91.ServerMethodDispatcher_0_91
Throws:
org.apache.qpid.AMQException

dispatchBasicRecoverSyncOk

public boolean dispatchBasicRecoverSyncOk(org.apache.qpid.framing.BasicRecoverSyncOkBody body,
                                          int channelId)
                                   throws org.apache.qpid.AMQException
Specified by:
dispatchBasicRecoverSyncOk in interface org.apache.qpid.framing.amqp_0_91.ClientMethodDispatcher_0_91
Throws:
org.apache.qpid.AMQException

dispatchChannelOk

public boolean dispatchChannelOk(org.apache.qpid.framing.ChannelOkBody body,
                                 int channelId)
                          throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchChannelPing

public boolean dispatchChannelPing(org.apache.qpid.framing.ChannelPingBody body,
                                   int channelId)
                            throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchChannelPong

public boolean dispatchChannelPong(org.apache.qpid.framing.ChannelPongBody body,
                                   int channelId)
                            throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchChannelResume

public boolean dispatchChannelResume(org.apache.qpid.framing.ChannelResumeBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageAppend

public boolean dispatchMessageAppend(org.apache.qpid.framing.MessageAppendBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageCancel

public boolean dispatchMessageCancel(org.apache.qpid.framing.MessageCancelBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageCheckpoint

public boolean dispatchMessageCheckpoint(org.apache.qpid.framing.MessageCheckpointBody body,
                                         int channelId)
                                  throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageClose

public boolean dispatchMessageClose(org.apache.qpid.framing.MessageCloseBody body,
                                    int channelId)
                             throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageConsume

public boolean dispatchMessageConsume(org.apache.qpid.framing.MessageConsumeBody body,
                                      int channelId)
                               throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageEmpty

public boolean dispatchMessageEmpty(org.apache.qpid.framing.MessageEmptyBody body,
                                    int channelId)
                             throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageGet

public boolean dispatchMessageGet(org.apache.qpid.framing.MessageGetBody body,
                                  int channelId)
                           throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageOffset

public boolean dispatchMessageOffset(org.apache.qpid.framing.MessageOffsetBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageOk

public boolean dispatchMessageOk(org.apache.qpid.framing.MessageOkBody body,
                                 int channelId)
                          throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageOpen

public boolean dispatchMessageOpen(org.apache.qpid.framing.MessageOpenBody body,
                                   int channelId)
                            throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageQos

public boolean dispatchMessageQos(org.apache.qpid.framing.MessageQosBody body,
                                  int channelId)
                           throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageRecover

public boolean dispatchMessageRecover(org.apache.qpid.framing.MessageRecoverBody body,
                                      int channelId)
                               throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageReject

public boolean dispatchMessageReject(org.apache.qpid.framing.MessageRejectBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageResume

public boolean dispatchMessageResume(org.apache.qpid.framing.MessageResumeBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchMessageTransfer

public boolean dispatchMessageTransfer(org.apache.qpid.framing.MessageTransferBody body,
                                       int channelId)
                                throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchBasicRecoverOk

public boolean dispatchBasicRecoverOk(org.apache.qpid.framing.BasicRecoverOkBody body,
                                      int channelId)
                               throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

dispatchQueueUnbindOk

public boolean dispatchQueueUnbindOk(org.apache.qpid.framing.QueueUnbindOkBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Specified by:
dispatchQueueUnbindOk in interface org.apache.qpid.framing.amqp_0_91.ClientMethodDispatcher_0_91
Throws:
org.apache.qpid.AMQException

dispatchQueueUnbind

public boolean dispatchQueueUnbind(org.apache.qpid.framing.QueueUnbindBody body,
                                   int channelId)
                            throws org.apache.qpid.AMQException
Specified by:
dispatchQueueUnbind in interface org.apache.qpid.framing.amqp_0_91.ServerMethodDispatcher_0_91
Throws:
org.apache.qpid.AMQException


Licensed to the Apache Software Foundation