org.apache.qpid.server.handler
Class ServerMethodDispatcherImpl_0_9
java.lang.Object
org.apache.qpid.server.handler.ServerMethodDispatcherImpl
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
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 |
ServerMethodDispatcherImpl_0_9
public ServerMethodDispatcherImpl_0_9(AMQStateManager stateManager)
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