org.apache.qpid.server.handler
Class ServerMethodDispatcherImpl_0_9

java.lang.Object
  extended by org.apache.qpid.server.handler.ServerMethodDispatcherImpl
      extended by org.apache.qpid.server.handler.ServerMethodDispatcherImpl_0_9
All Implemented Interfaces:
org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9, org.apache.qpid.framing.amqp_0_9.MethodDispatcher_0_9, org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9, org.apache.qpid.framing.ClientMethodDispatcher, org.apache.qpid.framing.MethodDispatcher, org.apache.qpid.framing.ServerMethodDispatcher

public class ServerMethodDispatcherImpl_0_9
extends ServerMethodDispatcherImpl
implements org.apache.qpid.framing.amqp_0_9.MethodDispatcher_0_9


Constructor Summary
ServerMethodDispatcherImpl_0_9(AMQStateManager stateManager)
           
 
Method Summary
 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_9.ServerMethodDispatcher_0_9
dispatchAccessRequest, dispatchBasicAck, dispatchBasicCancel, dispatchBasicConsume, dispatchBasicGet, dispatchBasicPublish, dispatchBasicQos, dispatchBasicRecover, dispatchBasicReject, dispatchChannelClose, dispatchChannelCloseOk, dispatchChannelFlow, dispatchChannelFlowOk, dispatchChannelOpen, dispatchConnectionClose, dispatchConnectionCloseOk, dispatchConnectionOpen, dispatchConnectionSecureOk, dispatchConnectionStartOk, dispatchConnectionTuneOk, dispatchDtxSelect, dispatchDtxStart, dispatchExchangeBound, dispatchExchangeDeclare, dispatchExchangeDelete, dispatchFileAck, dispatchFileCancel, dispatchFileConsume, dispatchFileOpen, dispatchFileOpenOk, dispatchFilePublish, dispatchFileQos, dispatchFileReject, dispatchFileStage, dispatchQueueBind, dispatchQueueDeclare, dispatchQueueDelete, dispatchQueuePurge, dispatchStreamCancel, dispatchStreamConsume, dispatchStreamPublish, dispatchStreamQos, dispatchTunnelRequest, dispatchTxCommit, dispatchTxRollback, dispatchTxSelect
 
Methods inherited from interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
dispatchAccessRequestOk, dispatchBasicCancelOk, dispatchBasicConsumeOk, dispatchBasicDeliver, dispatchBasicGetEmpty, dispatchBasicGetOk, dispatchBasicQosOk, dispatchBasicReturn, dispatchChannelClose, dispatchChannelCloseOk, dispatchChannelFlow, dispatchChannelFlowOk, dispatchChannelOpenOk, dispatchConnectionClose, dispatchConnectionCloseOk, dispatchConnectionOpenOk, dispatchConnectionRedirect, dispatchConnectionSecure, dispatchConnectionStart, dispatchConnectionTune, dispatchDtxSelectOk, dispatchDtxStartOk, dispatchExchangeBoundOk, dispatchExchangeDeclareOk, dispatchExchangeDeleteOk, dispatchFileCancelOk, dispatchFileConsumeOk, dispatchFileDeliver, dispatchFileOpen, dispatchFileOpenOk, dispatchFileQosOk, dispatchFileReturn, dispatchFileStage, dispatchQueueBindOk, dispatchQueueDeclareOk, dispatchQueueDeleteOk, dispatchQueuePurgeOk, dispatchStreamCancelOk, dispatchStreamConsumeOk, dispatchStreamDeliver, dispatchStreamQosOk, dispatchStreamReturn, dispatchTxCommitOk, dispatchTxRollbackOk, dispatchTxSelectOk
 

Constructor Detail

ServerMethodDispatcherImpl_0_9

public ServerMethodDispatcherImpl_0_9(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_9.ServerMethodDispatcher_0_9
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_9.ClientMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchChannelOk

public boolean dispatchChannelOk(org.apache.qpid.framing.ChannelOkBody body,
                                 int channelId)
                          throws org.apache.qpid.AMQException
Specified by:
dispatchChannelOk in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchChannelOk in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchChannelPing

public boolean dispatchChannelPing(org.apache.qpid.framing.ChannelPingBody body,
                                   int channelId)
                            throws org.apache.qpid.AMQException
Specified by:
dispatchChannelPing in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchChannelPing in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchChannelPong

public boolean dispatchChannelPong(org.apache.qpid.framing.ChannelPongBody body,
                                   int channelId)
                            throws org.apache.qpid.AMQException
Specified by:
dispatchChannelPong in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchChannelPong in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchChannelResume

public boolean dispatchChannelResume(org.apache.qpid.framing.ChannelResumeBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Specified by:
dispatchChannelResume in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageAppend

public boolean dispatchMessageAppend(org.apache.qpid.framing.MessageAppendBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Specified by:
dispatchMessageAppend in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageAppend in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageCancel

public boolean dispatchMessageCancel(org.apache.qpid.framing.MessageCancelBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Specified by:
dispatchMessageCancel in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageCheckpoint

public boolean dispatchMessageCheckpoint(org.apache.qpid.framing.MessageCheckpointBody body,
                                         int channelId)
                                  throws org.apache.qpid.AMQException
Specified by:
dispatchMessageCheckpoint in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageCheckpoint in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageClose

public boolean dispatchMessageClose(org.apache.qpid.framing.MessageCloseBody body,
                                    int channelId)
                             throws org.apache.qpid.AMQException
Specified by:
dispatchMessageClose in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageClose in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageConsume

public boolean dispatchMessageConsume(org.apache.qpid.framing.MessageConsumeBody body,
                                      int channelId)
                               throws org.apache.qpid.AMQException
Specified by:
dispatchMessageConsume in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageEmpty

public boolean dispatchMessageEmpty(org.apache.qpid.framing.MessageEmptyBody body,
                                    int channelId)
                             throws org.apache.qpid.AMQException
Specified by:
dispatchMessageEmpty in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageEmpty in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageGet

public boolean dispatchMessageGet(org.apache.qpid.framing.MessageGetBody body,
                                  int channelId)
                           throws org.apache.qpid.AMQException
Specified by:
dispatchMessageGet in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageOffset

public boolean dispatchMessageOffset(org.apache.qpid.framing.MessageOffsetBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Specified by:
dispatchMessageOffset in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageOffset in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageOk

public boolean dispatchMessageOk(org.apache.qpid.framing.MessageOkBody body,
                                 int channelId)
                          throws org.apache.qpid.AMQException
Specified by:
dispatchMessageOk in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageOk in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageOpen

public boolean dispatchMessageOpen(org.apache.qpid.framing.MessageOpenBody body,
                                   int channelId)
                            throws org.apache.qpid.AMQException
Specified by:
dispatchMessageOpen in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageOpen in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageQos

public boolean dispatchMessageQos(org.apache.qpid.framing.MessageQosBody body,
                                  int channelId)
                           throws org.apache.qpid.AMQException
Specified by:
dispatchMessageQos in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageRecover

public boolean dispatchMessageRecover(org.apache.qpid.framing.MessageRecoverBody body,
                                      int channelId)
                               throws org.apache.qpid.AMQException
Specified by:
dispatchMessageRecover in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageReject

public boolean dispatchMessageReject(org.apache.qpid.framing.MessageRejectBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Specified by:
dispatchMessageReject in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageReject in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageResume

public boolean dispatchMessageResume(org.apache.qpid.framing.MessageResumeBody body,
                                     int channelId)
                              throws org.apache.qpid.AMQException
Specified by:
dispatchMessageResume in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageResume in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException

dispatchMessageTransfer

public boolean dispatchMessageTransfer(org.apache.qpid.framing.MessageTransferBody body,
                                       int channelId)
                                throws org.apache.qpid.AMQException
Specified by:
dispatchMessageTransfer in interface org.apache.qpid.framing.amqp_0_9.ClientMethodDispatcher_0_9
Specified by:
dispatchMessageTransfer in interface org.apache.qpid.framing.amqp_0_9.ServerMethodDispatcher_0_9
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_9.ClientMethodDispatcher_0_9
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_9.ServerMethodDispatcher_0_9
Throws:
org.apache.qpid.AMQException


Licensed to the Apache Software Foundation