org.apache.qpid.server.handler
Class ServerMethodDispatcherImpl_0_91
java.lang.Object
org.apache.qpid.server.handler.ServerMethodDispatcherImpl
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
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 |
ServerMethodDispatcherImpl_0_91
public ServerMethodDispatcherImpl_0_91(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_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