public class ClientMethodDispatcherImpl extends Object implements MethodDispatcher
Constructor and Description |
---|
ClientMethodDispatcherImpl(AMQProtocolSession session) |
public ClientMethodDispatcherImpl(AMQProtocolSession session)
public static ClientMethodDispatcherImpl newMethodDispatcher(ProtocolVersion version, AMQProtocolSession session)
public AMQStateManager getStateManager()
public boolean dispatchAccessRequestOk(AccessRequestOkBody body, int channelId) throws QpidException
dispatchAccessRequestOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchQueueUnbindOk(QueueUnbindOkBody body, int channelId) throws QpidException
dispatchQueueUnbindOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchBasicRecoverSyncOk(BasicRecoverSyncOkBody basicRecoverSyncOkBody, int channelId) throws QpidException
dispatchBasicRecoverSyncOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchChannelAlert(ChannelAlertBody channelAlertBody, int channelId) throws QpidException
dispatchChannelAlert
in interface ClientMethodDispatcher
QpidException
public boolean dispatchConfirmSelectOk(ConfirmSelectOkBody confirmSelectOkBody, int channelId) throws QpidException
dispatchConfirmSelectOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchBasicCancelOk(BasicCancelOkBody body, int channelId) throws QpidException
dispatchBasicCancelOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchBasicConsumeOk(BasicConsumeOkBody body, int channelId) throws QpidException
dispatchBasicConsumeOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchBasicDeliver(BasicDeliverBody body, int channelId) throws QpidException
dispatchBasicDeliver
in interface ClientMethodDispatcher
QpidException
public boolean dispatchBasicGetEmpty(BasicGetEmptyBody body, int channelId) throws QpidException
dispatchBasicGetEmpty
in interface ClientMethodDispatcher
QpidException
public boolean dispatchBasicGetOk(BasicGetOkBody body, int channelId) throws QpidException
dispatchBasicGetOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchBasicQosOk(BasicQosOkBody body, int channelId) throws QpidException
dispatchBasicQosOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchBasicReturn(BasicReturnBody body, int channelId) throws QpidException
dispatchBasicReturn
in interface ClientMethodDispatcher
QpidException
public boolean dispatchChannelClose(ChannelCloseBody body, int channelId) throws QpidException
dispatchChannelClose
in interface ClientMethodDispatcher
dispatchChannelClose
in interface ServerMethodDispatcher
QpidException
public boolean dispatchChannelCloseOk(ChannelCloseOkBody body, int channelId) throws QpidException
dispatchChannelCloseOk
in interface ClientMethodDispatcher
dispatchChannelCloseOk
in interface ServerMethodDispatcher
QpidException
public boolean dispatchChannelFlow(ChannelFlowBody body, int channelId) throws QpidException
dispatchChannelFlow
in interface ClientMethodDispatcher
dispatchChannelFlow
in interface ServerMethodDispatcher
QpidException
public boolean dispatchChannelFlowOk(ChannelFlowOkBody body, int channelId) throws QpidException
dispatchChannelFlowOk
in interface ClientMethodDispatcher
dispatchChannelFlowOk
in interface ServerMethodDispatcher
QpidException
public boolean dispatchChannelOpenOk(ChannelOpenOkBody body, int channelId) throws QpidException
dispatchChannelOpenOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchConnectionClose(ConnectionCloseBody body, int channelId) throws QpidException
dispatchConnectionClose
in interface ClientMethodDispatcher
dispatchConnectionClose
in interface ServerMethodDispatcher
QpidException
public boolean dispatchConnectionCloseOk(ConnectionCloseOkBody body, int channelId) throws QpidException
dispatchConnectionCloseOk
in interface ClientMethodDispatcher
dispatchConnectionCloseOk
in interface ServerMethodDispatcher
QpidException
public boolean dispatchConnectionOpenOk(ConnectionOpenOkBody body, int channelId) throws QpidException
dispatchConnectionOpenOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchConnectionRedirect(ConnectionRedirectBody body, int channelId) throws QpidException
dispatchConnectionRedirect
in interface ClientMethodDispatcher
QpidException
public boolean dispatchConnectionSecure(ConnectionSecureBody body, int channelId) throws QpidException
dispatchConnectionSecure
in interface ClientMethodDispatcher
QpidException
public boolean dispatchConnectionStart(ConnectionStartBody body, int channelId) throws QpidException
dispatchConnectionStart
in interface ClientMethodDispatcher
QpidException
public boolean dispatchConnectionTune(ConnectionTuneBody body, int channelId) throws QpidException
dispatchConnectionTune
in interface ClientMethodDispatcher
QpidException
public boolean dispatchQueueDeleteOk(QueueDeleteOkBody body, int channelId) throws QpidException
dispatchQueueDeleteOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchQueuePurgeOk(QueuePurgeOkBody body, int channelId) throws QpidException
dispatchQueuePurgeOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchAccessRequest(AccessRequestBody body, int channelId) throws QpidException
dispatchAccessRequest
in interface ServerMethodDispatcher
QpidException
public boolean dispatchBasicAck(BasicAckBody body, int channelId) throws QpidException
dispatchBasicAck
in interface ServerMethodDispatcher
QpidException
public boolean dispatchBasicNack(BasicNackBody basicNackBody, int channelId)
dispatchBasicNack
in interface MethodDispatcher
public boolean dispatchBasicCancel(BasicCancelBody body, int channelId) throws QpidException
dispatchBasicCancel
in interface ServerMethodDispatcher
QpidException
public boolean dispatchBasicConsume(BasicConsumeBody body, int channelId) throws QpidException
dispatchBasicConsume
in interface ServerMethodDispatcher
QpidException
public boolean dispatchBasicGet(BasicGetBody body, int channelId) throws QpidException
dispatchBasicGet
in interface ServerMethodDispatcher
QpidException
public boolean dispatchBasicPublish(BasicPublishBody body, int channelId) throws QpidException
dispatchBasicPublish
in interface ServerMethodDispatcher
QpidException
public boolean dispatchBasicQos(BasicQosBody body, int channelId) throws QpidException
dispatchBasicQos
in interface ServerMethodDispatcher
QpidException
public boolean dispatchBasicRecover(BasicRecoverBody body, int channelId) throws QpidException
dispatchBasicRecover
in interface ServerMethodDispatcher
QpidException
public boolean dispatchBasicReject(BasicRejectBody body, int channelId) throws QpidException
dispatchBasicReject
in interface ServerMethodDispatcher
QpidException
public boolean dispatchChannelOpen(ChannelOpenBody body, int channelId) throws QpidException
dispatchChannelOpen
in interface ServerMethodDispatcher
QpidException
public boolean dispatchConnectionOpen(ConnectionOpenBody body, int channelId) throws QpidException
dispatchConnectionOpen
in interface ServerMethodDispatcher
QpidException
public boolean dispatchConnectionSecureOk(ConnectionSecureOkBody body, int channelId) throws QpidException
dispatchConnectionSecureOk
in interface ServerMethodDispatcher
QpidException
public boolean dispatchConnectionStartOk(ConnectionStartOkBody body, int channelId) throws QpidException
dispatchConnectionStartOk
in interface ServerMethodDispatcher
QpidException
public boolean dispatchConnectionTuneOk(ConnectionTuneOkBody body, int channelId) throws QpidException
dispatchConnectionTuneOk
in interface ServerMethodDispatcher
QpidException
public boolean dispatchExchangeBound(ExchangeBoundBody body, int channelId) throws QpidException
dispatchExchangeBound
in interface ServerMethodDispatcher
QpidException
public boolean dispatchExchangeDeclare(ExchangeDeclareBody body, int channelId) throws QpidException
dispatchExchangeDeclare
in interface ServerMethodDispatcher
QpidException
public boolean dispatchExchangeDelete(ExchangeDeleteBody body, int channelId) throws QpidException
dispatchExchangeDelete
in interface ServerMethodDispatcher
QpidException
public boolean dispatchQueueBind(QueueBindBody body, int channelId) throws QpidException
dispatchQueueBind
in interface ServerMethodDispatcher
QpidException
public boolean dispatchQueueDeclare(QueueDeclareBody body, int channelId) throws QpidException
dispatchQueueDeclare
in interface ServerMethodDispatcher
QpidException
public boolean dispatchQueueDelete(QueueDeleteBody body, int channelId) throws QpidException
dispatchQueueDelete
in interface ServerMethodDispatcher
QpidException
public boolean dispatchQueuePurge(QueuePurgeBody body, int channelId) throws QpidException
dispatchQueuePurge
in interface ServerMethodDispatcher
QpidException
public boolean dispatchTxCommit(TxCommitBody body, int channelId) throws QpidException
dispatchTxCommit
in interface ServerMethodDispatcher
QpidException
public boolean dispatchTxRollback(TxRollbackBody body, int channelId) throws QpidException
dispatchTxRollback
in interface ServerMethodDispatcher
QpidException
public boolean dispatchTxSelect(TxSelectBody body, int channelId) throws QpidException
dispatchTxSelect
in interface ServerMethodDispatcher
QpidException
public boolean dispatchQueueUnbind(QueueUnbindBody queueUnbindBody, int channelId) throws QpidException
dispatchQueueUnbind
in interface ServerMethodDispatcher
QpidException
public boolean dispatchBasicRecoverSync(BasicRecoverSyncBody basicRecoverSyncBody, int channelId) throws QpidException
dispatchBasicRecoverSync
in interface ServerMethodDispatcher
QpidException
public boolean dispatchConfirmSelect(ConfirmSelectBody body, int channelId) throws QpidException
dispatchConfirmSelect
in interface ServerMethodDispatcher
QpidException
public boolean dispatchExchangeBoundOk(ExchangeBoundOkBody body, int channelId) throws QpidException
dispatchExchangeBoundOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchExchangeDeclareOk(ExchangeDeclareOkBody body, int channelId) throws QpidException
dispatchExchangeDeclareOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchExchangeDeleteOk(ExchangeDeleteOkBody body, int channelId) throws QpidException
dispatchExchangeDeleteOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchQueueBindOk(QueueBindOkBody body, int channelId) throws QpidException
dispatchQueueBindOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchQueueDeclareOk(QueueDeclareOkBody body, int channelId) throws QpidException
dispatchQueueDeclareOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchTxCommitOk(TxCommitOkBody body, int channelId) throws QpidException
dispatchTxCommitOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchTxRollbackOk(TxRollbackOkBody body, int channelId) throws QpidException
dispatchTxRollbackOk
in interface ClientMethodDispatcher
QpidException
public boolean dispatchTxSelectOk(TxSelectOkBody body, int channelId) throws QpidException
dispatchTxSelectOk
in interface ClientMethodDispatcher
QpidException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.