org.apache.qpid.framing
Interface AMQMethodBody

All Superinterfaces:
AMQBody
All Known Subinterfaces:
AccessRequestBody, AccessRequestOkBody, BasicAckBody, BasicCancelBody, BasicCancelOkBody, BasicConsumeBody, BasicConsumeOkBody, BasicDeliverBody, BasicGetBody, BasicGetEmptyBody, BasicGetOkBody, BasicPublishBody, BasicQosBody, BasicQosOkBody, BasicRecoverBody, BasicRecoverOkBody, BasicRecoverSyncBody, BasicRecoverSyncOkBody, BasicRejectBody, BasicReturnBody, ChannelAlertBody, ChannelCloseBody, ChannelCloseOkBody, ChannelFlowBody, ChannelFlowOkBody, ChannelOkBody, ChannelOpenBody, ChannelOpenOkBody, ChannelPingBody, ChannelPongBody, ChannelResumeBody, ConnectionCloseBody, ConnectionCloseOkBody, ConnectionOpenBody, ConnectionOpenOkBody, ConnectionRedirectBody, ConnectionSecureBody, ConnectionSecureOkBody, ConnectionStartBody, ConnectionStartOkBody, ConnectionTuneBody, ConnectionTuneOkBody, DtxSelectBody, DtxSelectOkBody, DtxStartBody, DtxStartOkBody, ExchangeBoundBody, ExchangeBoundOkBody, ExchangeDeclareBody, ExchangeDeclareOkBody, ExchangeDeleteBody, ExchangeDeleteOkBody, FileAckBody, FileCancelBody, FileCancelOkBody, FileConsumeBody, FileConsumeOkBody, FileDeliverBody, FileOpenBody, FileOpenOkBody, FilePublishBody, FileQosBody, FileQosOkBody, FileRejectBody, FileReturnBody, FileStageBody, MessageAppendBody, MessageCancelBody, MessageCheckpointBody, MessageCloseBody, MessageConsumeBody, MessageEmptyBody, MessageGetBody, MessageOffsetBody, MessageOkBody, MessageOpenBody, MessageQosBody, MessageRecoverBody, MessageRejectBody, MessageResumeBody, MessageTransferBody, QueueBindBody, QueueBindOkBody, QueueDeclareBody, QueueDeclareOkBody, QueueDeleteBody, QueueDeleteOkBody, QueuePurgeBody, QueuePurgeOkBody, QueueUnbindBody, QueueUnbindOkBody, StreamCancelBody, StreamCancelOkBody, StreamConsumeBody, StreamConsumeOkBody, StreamDeliverBody, StreamPublishBody, StreamQosBody, StreamQosOkBody, StreamReturnBody, TestContentBody, TestContentOkBody, TestIntegerBody, TestIntegerOkBody, TestStringBody, TestStringOkBody, TestTableBody, TestTableOkBody, TunnelRequestBody, TxCommitBody, TxCommitOkBody, TxRollbackBody, TxRollbackOkBody, TxSelectBody, TxSelectOkBody
All Known Implementing Classes:
AccessRequestBodyImpl, AccessRequestBodyImpl, AccessRequestOkBodyImpl, AccessRequestOkBodyImpl, AMQMethodBody_0_9, AMQMethodBody_0_91, AMQMethodBody_8_0, AMQMethodBodyImpl, BasicAckBodyImpl, BasicAckBodyImpl, BasicAckBodyImpl, BasicCancelBodyImpl, BasicCancelBodyImpl, BasicCancelBodyImpl, BasicCancelOkBodyImpl, BasicCancelOkBodyImpl, BasicCancelOkBodyImpl, BasicConsumeBodyImpl, BasicConsumeBodyImpl, BasicConsumeBodyImpl, BasicConsumeOkBodyImpl, BasicConsumeOkBodyImpl, BasicConsumeOkBodyImpl, BasicDeliverBodyImpl, BasicDeliverBodyImpl, BasicDeliverBodyImpl, BasicGetBodyImpl, BasicGetBodyImpl, BasicGetBodyImpl, BasicGetEmptyBodyImpl, BasicGetEmptyBodyImpl, BasicGetEmptyBodyImpl, BasicGetOkBodyImpl, BasicGetOkBodyImpl, BasicGetOkBodyImpl, BasicPublishBodyImpl, BasicPublishBodyImpl, BasicPublishBodyImpl, BasicQosBodyImpl, BasicQosBodyImpl, BasicQosBodyImpl, BasicQosOkBodyImpl, BasicQosOkBodyImpl, BasicQosOkBodyImpl, BasicRecoverBodyImpl, BasicRecoverBodyImpl, BasicRecoverBodyImpl, BasicRecoverOkBodyImpl, BasicRecoverSyncBodyImpl, BasicRecoverSyncBodyImpl, BasicRecoverSyncOkBodyImpl, BasicRecoverSyncOkBodyImpl, BasicRejectBodyImpl, BasicRejectBodyImpl, BasicRejectBodyImpl, BasicReturnBodyImpl, BasicReturnBodyImpl, BasicReturnBodyImpl, ChannelAlertBodyImpl, ChannelCloseBodyImpl, ChannelCloseBodyImpl, ChannelCloseBodyImpl, ChannelCloseOkBodyImpl, ChannelCloseOkBodyImpl, ChannelCloseOkBodyImpl, ChannelFlowBodyImpl, ChannelFlowBodyImpl, ChannelFlowBodyImpl, ChannelFlowOkBodyImpl, ChannelFlowOkBodyImpl, ChannelFlowOkBodyImpl, ChannelOkBodyImpl, ChannelOpenBodyImpl, ChannelOpenBodyImpl, ChannelOpenBodyImpl, ChannelOpenOkBodyImpl, ChannelOpenOkBodyImpl, ChannelOpenOkBodyImpl, ChannelPingBodyImpl, ChannelPongBodyImpl, ChannelResumeBodyImpl, ConnectionCloseBodyImpl, ConnectionCloseBodyImpl, ConnectionCloseBodyImpl, ConnectionCloseOkBodyImpl, ConnectionCloseOkBodyImpl, ConnectionCloseOkBodyImpl, ConnectionOpenBodyImpl, ConnectionOpenBodyImpl, ConnectionOpenBodyImpl, ConnectionOpenOkBodyImpl, ConnectionOpenOkBodyImpl, ConnectionOpenOkBodyImpl, ConnectionRedirectBodyImpl, ConnectionRedirectBodyImpl, ConnectionSecureBodyImpl, ConnectionSecureBodyImpl, ConnectionSecureBodyImpl, ConnectionSecureOkBodyImpl, ConnectionSecureOkBodyImpl, ConnectionSecureOkBodyImpl, ConnectionStartBodyImpl, ConnectionStartBodyImpl, ConnectionStartBodyImpl, ConnectionStartOkBodyImpl, ConnectionStartOkBodyImpl, ConnectionStartOkBodyImpl, ConnectionTuneBodyImpl, ConnectionTuneBodyImpl, ConnectionTuneBodyImpl, ConnectionTuneOkBodyImpl, ConnectionTuneOkBodyImpl, ConnectionTuneOkBodyImpl, DtxSelectBodyImpl, DtxSelectBodyImpl, DtxSelectOkBodyImpl, DtxSelectOkBodyImpl, DtxStartBodyImpl, DtxStartBodyImpl, DtxStartOkBodyImpl, DtxStartOkBodyImpl, ExchangeBoundBodyImpl, ExchangeBoundBodyImpl, ExchangeBoundBodyImpl, ExchangeBoundOkBodyImpl, ExchangeBoundOkBodyImpl, ExchangeBoundOkBodyImpl, ExchangeDeclareBodyImpl, ExchangeDeclareBodyImpl, ExchangeDeclareBodyImpl, ExchangeDeclareOkBodyImpl, ExchangeDeclareOkBodyImpl, ExchangeDeclareOkBodyImpl, ExchangeDeleteBodyImpl, ExchangeDeleteBodyImpl, ExchangeDeleteBodyImpl, ExchangeDeleteOkBodyImpl, ExchangeDeleteOkBodyImpl, ExchangeDeleteOkBodyImpl, FileAckBodyImpl, FileAckBodyImpl, FileCancelBodyImpl, FileCancelBodyImpl, FileCancelOkBodyImpl, FileCancelOkBodyImpl, FileConsumeBodyImpl, FileConsumeBodyImpl, FileConsumeOkBodyImpl, FileConsumeOkBodyImpl, FileDeliverBodyImpl, FileDeliverBodyImpl, FileOpenBodyImpl, FileOpenBodyImpl, FileOpenOkBodyImpl, FileOpenOkBodyImpl, FilePublishBodyImpl, FilePublishBodyImpl, FileQosBodyImpl, FileQosBodyImpl, FileQosOkBodyImpl, FileQosOkBodyImpl, FileRejectBodyImpl, FileRejectBodyImpl, FileReturnBodyImpl, FileReturnBodyImpl, FileStageBodyImpl, FileStageBodyImpl, MessageAppendBodyImpl, MessageCancelBodyImpl, MessageCheckpointBodyImpl, MessageCloseBodyImpl, MessageConsumeBodyImpl, MessageEmptyBodyImpl, MessageGetBodyImpl, MessageOffsetBodyImpl, MessageOkBodyImpl, MessageOpenBodyImpl, MessageQosBodyImpl, MessageRecoverBodyImpl, MessageRejectBodyImpl, MessageResumeBodyImpl, MessageTransferBodyImpl, QueueBindBodyImpl, QueueBindBodyImpl, QueueBindBodyImpl, QueueBindOkBodyImpl, QueueBindOkBodyImpl, QueueBindOkBodyImpl, QueueDeclareBodyImpl, QueueDeclareBodyImpl, QueueDeclareBodyImpl, QueueDeclareOkBodyImpl, QueueDeclareOkBodyImpl, QueueDeclareOkBodyImpl, QueueDeleteBodyImpl, QueueDeleteBodyImpl, QueueDeleteBodyImpl, QueueDeleteOkBodyImpl, QueueDeleteOkBodyImpl, QueueDeleteOkBodyImpl, QueuePurgeBodyImpl, QueuePurgeBodyImpl, QueuePurgeBodyImpl, QueuePurgeOkBodyImpl, QueuePurgeOkBodyImpl, QueuePurgeOkBodyImpl, QueueUnbindBodyImpl, QueueUnbindBodyImpl, QueueUnbindOkBodyImpl, QueueUnbindOkBodyImpl, StreamCancelBodyImpl, StreamCancelBodyImpl, StreamCancelOkBodyImpl, StreamCancelOkBodyImpl, StreamConsumeBodyImpl, StreamConsumeBodyImpl, StreamConsumeOkBodyImpl, StreamConsumeOkBodyImpl, StreamDeliverBodyImpl, StreamDeliverBodyImpl, StreamPublishBodyImpl, StreamPublishBodyImpl, StreamQosBodyImpl, StreamQosBodyImpl, StreamQosOkBodyImpl, StreamQosOkBodyImpl, StreamReturnBodyImpl, StreamReturnBodyImpl, TestContentBodyImpl, TestContentOkBodyImpl, TestIntegerBodyImpl, TestIntegerOkBodyImpl, TestStringBodyImpl, TestStringOkBodyImpl, TestTableBodyImpl, TestTableOkBodyImpl, TunnelRequestBodyImpl, TunnelRequestBodyImpl, TxCommitBodyImpl, TxCommitBodyImpl, TxCommitBodyImpl, TxCommitOkBodyImpl, TxCommitOkBodyImpl, TxCommitOkBodyImpl, TxRollbackBodyImpl, TxRollbackBodyImpl, TxRollbackBodyImpl, TxRollbackOkBodyImpl, TxRollbackOkBodyImpl, TxRollbackOkBodyImpl, TxSelectBodyImpl, TxSelectBodyImpl, TxSelectBodyImpl, TxSelectOkBodyImpl, TxSelectOkBodyImpl, TxSelectOkBodyImpl

public interface AMQMethodBody
extends AMQBody


Field Summary
static byte TYPE
           
 
Method Summary
 boolean execute(MethodDispatcher methodDispatcher, int channelId)
           
 AMQFrame generateFrame(int channelId)
           
 AMQChannelException getChannelException(AMQConstant code, String message)
           
 AMQChannelException getChannelException(AMQConstant code, String message, Throwable cause)
           
 AMQChannelException getChannelNotFoundException(int channelId)
          Convenience Method to create a channel not found exception
 int getClazz()
           
 AMQConnectionException getConnectionException(AMQConstant code, String message)
           
 AMQConnectionException getConnectionException(AMQConstant code, String message, Throwable cause)
           
 byte getMajor()
          AMQP version
 int getMethod()
           
 byte getMinor()
           
 int getSize()
          Get the size of the body
 String toString()
           
 void writeMethodPayload(org.apache.mina.common.ByteBuffer buffer)
           
 void writePayload(org.apache.mina.common.ByteBuffer buffer)
           
 
Methods inherited from interface org.apache.qpid.framing.AMQBody
getFrameType, handle
 

Field Detail

TYPE

static final byte TYPE
See Also:
Constant Field Values
Method Detail

getMajor

byte getMajor()
AMQP version


getMinor

byte getMinor()

getClazz

int getClazz()
Returns:
unsigned short

getMethod

int getMethod()
Returns:
unsigned short

writeMethodPayload

void writeMethodPayload(org.apache.mina.common.ByteBuffer buffer)

getSize

int getSize()
Description copied from interface: AMQBody
Get the size of the body

Specified by:
getSize in interface AMQBody
Returns:
unsigned short

writePayload

void writePayload(org.apache.mina.common.ByteBuffer buffer)
Specified by:
writePayload in interface AMQBody

generateFrame

AMQFrame generateFrame(int channelId)

toString

String toString()
Overrides:
toString in class Object

getChannelNotFoundException

AMQChannelException getChannelNotFoundException(int channelId)
Convenience Method to create a channel not found exception

Parameters:
channelId - The channel id that is not found
Returns:
new AMQChannelException

getChannelException

AMQChannelException getChannelException(AMQConstant code,
                                        String message)

getChannelException

AMQChannelException getChannelException(AMQConstant code,
                                        String message,
                                        Throwable cause)

getConnectionException

AMQConnectionException getConnectionException(AMQConstant code,
                                              String message)

getConnectionException

AMQConnectionException getConnectionException(AMQConstant code,
                                              String message,
                                              Throwable cause)

execute

boolean execute(MethodDispatcher methodDispatcher,
                int channelId)
                throws AMQException
Throws:
AMQException


Licensed to the Apache Software Foundation