org.apache.qpid.framing.amqp_0_9
Class MethodRegistry_0_9

java.lang.Object
  extended by org.apache.qpid.framing.MethodRegistry
      extended by org.apache.qpid.framing.amqp_0_9.MethodRegistry_0_9

public class MethodRegistry_0_9
extends MethodRegistry


Field Summary
 
Fields inherited from class org.apache.qpid.framing.MethodRegistry
registry_0_9, registry_0_91, registry_8_0
 
Constructor Summary
MethodRegistry_0_9()
           
MethodRegistry_0_9(ProtocolVersion pv)
           
 
Method Summary
 AMQMethodBody convertToBody(org.apache.mina.common.ByteBuffer in, long size)
           
 AccessRequestBody createAccessRequestBody(AMQShortString realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read)
           
 AccessRequestOkBody createAccessRequestOkBody(int ticket)
           
 BasicAckBody createBasicAckBody(long deliveryTag, boolean multiple)
           
 BasicCancelBody createBasicCancelBody(AMQShortString consumerTag, boolean nowait)
           
 BasicCancelOkBody createBasicCancelOkBody(AMQShortString consumerTag)
           
 BasicConsumeBody createBasicConsumeBody(int ticket, AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, FieldTable arguments)
           
 BasicConsumeOkBody createBasicConsumeOkBody(AMQShortString consumerTag)
           
 BasicDeliverBody createBasicDeliverBody(AMQShortString consumerTag, long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey)
           
 BasicGetBody createBasicGetBody(int ticket, AMQShortString queue, boolean noAck)
           
 BasicGetEmptyBody createBasicGetEmptyBody(AMQShortString clusterId)
           
 BasicGetOkBody createBasicGetOkBody(long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey, long messageCount)
           
 BasicPublishBody createBasicPublishBody(int ticket, AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate)
           
 BasicQosBody createBasicQosBody(long prefetchSize, int prefetchCount, boolean global)
           
 BasicQosOkBody createBasicQosOkBody()
           
 BasicRecoverBody createBasicRecoverBody(boolean requeue)
           
 BasicRecoverSyncBody createBasicRecoverSyncBody(boolean requeue)
           
 BasicRecoverSyncOkBody createBasicRecoverSyncOkBody()
           
 BasicRejectBody createBasicRejectBody(long deliveryTag, boolean requeue)
           
 BasicReturnBody createBasicReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
           
 ChannelCloseBody createChannelCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
           
 ChannelCloseOkBody createChannelCloseOkBody()
           
 ChannelFlowBody createChannelFlowBody(boolean active)
           
 ChannelFlowOkBody createChannelFlowOkBody(boolean active)
           
 ChannelOkBody createChannelOkBody()
           
 ChannelOpenBody createChannelOpenBody(AMQShortString outOfBand)
           
 ChannelOpenOkBody createChannelOpenOkBody(byte[] channelId)
           
 ChannelPingBody createChannelPingBody()
           
 ChannelPongBody createChannelPongBody()
           
 ChannelResumeBody createChannelResumeBody(byte[] channelId)
           
 ConnectionCloseBody createConnectionCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
           
 ConnectionCloseOkBody createConnectionCloseOkBody()
           
 ConnectionOpenBody createConnectionOpenBody(AMQShortString virtualHost, AMQShortString capabilities, boolean insist)
           
 ConnectionOpenOkBody createConnectionOpenOkBody(AMQShortString knownHosts)
           
 ConnectionRedirectBody createConnectionRedirectBody(AMQShortString host, AMQShortString knownHosts)
           
 ConnectionSecureBody createConnectionSecureBody(byte[] challenge)
           
 ConnectionSecureOkBody createConnectionSecureOkBody(byte[] response)
           
 ConnectionStartBody createConnectionStartBody(short versionMajor, short versionMinor, FieldTable serverProperties, byte[] mechanisms, byte[] locales)
           
 ConnectionStartOkBody createConnectionStartOkBody(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
           
 ConnectionTuneBody createConnectionTuneBody(int channelMax, long frameMax, int heartbeat)
           
 ConnectionTuneOkBody createConnectionTuneOkBody(int channelMax, long frameMax, int heartbeat)
           
 DtxSelectBody createDtxSelectBody()
           
 DtxSelectOkBody createDtxSelectOkBody()
           
 DtxStartBody createDtxStartBody(AMQShortString dtxIdentifier)
           
 DtxStartOkBody createDtxStartOkBody()
           
 ExchangeBoundBody createExchangeBoundBody(AMQShortString exchange, AMQShortString routingKey, AMQShortString queue)
           
 ExchangeBoundOkBody createExchangeBoundOkBody(int replyCode, AMQShortString replyText)
           
 ExchangeDeclareBody createExchangeDeclareBody(int ticket, AMQShortString exchange, AMQShortString type, boolean passive, boolean durable, boolean autoDelete, boolean internal, boolean nowait, FieldTable arguments)
           
 ExchangeDeclareOkBody createExchangeDeclareOkBody()
           
 ExchangeDeleteBody createExchangeDeleteBody(int ticket, AMQShortString exchange, boolean ifUnused, boolean nowait)
           
 ExchangeDeleteOkBody createExchangeDeleteOkBody()
           
 FileAckBody createFileAckBody(long deliveryTag, boolean multiple)
           
 FileCancelBody createFileCancelBody(AMQShortString consumerTag, boolean nowait)
           
 FileCancelOkBody createFileCancelOkBody(AMQShortString consumerTag)
           
 FileConsumeBody createFileConsumeBody(int ticket, AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, FieldTable filter)
           
 FileConsumeOkBody createFileConsumeOkBody(AMQShortString consumerTag)
           
 FileDeliverBody createFileDeliverBody(AMQShortString consumerTag, long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey, AMQShortString identifier)
           
 FileOpenBody createFileOpenBody(AMQShortString identifier, long contentSize)
           
 FileOpenOkBody createFileOpenOkBody(long stagedSize)
           
 FilePublishBody createFilePublishBody(int ticket, AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate, AMQShortString identifier)
           
 FileQosBody createFileQosBody(long prefetchSize, int prefetchCount, boolean global)
           
 FileQosOkBody createFileQosOkBody()
           
 FileRejectBody createFileRejectBody(long deliveryTag, boolean requeue)
           
 FileReturnBody createFileReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
           
 FileStageBody createFileStageBody()
           
 MessageAppendBody createMessageAppendBody(byte[] reference, byte[] bytes)
           
 MessageCancelBody createMessageCancelBody(AMQShortString destination)
           
 MessageCheckpointBody createMessageCheckpointBody(byte[] reference, AMQShortString identifier)
           
 MessageCloseBody createMessageCloseBody(byte[] reference)
           
 MessageConsumeBody createMessageConsumeBody(int ticket, AMQShortString queue, AMQShortString destination, boolean noLocal, boolean noAck, boolean exclusive, FieldTable filter)
           
 MessageEmptyBody createMessageEmptyBody()
           
 MessageGetBody createMessageGetBody(int ticket, AMQShortString queue, AMQShortString destination, boolean noAck)
           
 MessageOffsetBody createMessageOffsetBody(long value)
           
 MessageOkBody createMessageOkBody()
           
 MessageOpenBody createMessageOpenBody(byte[] reference)
           
 MessageQosBody createMessageQosBody(long prefetchSize, int prefetchCount, boolean global)
           
 MessageRecoverBody createMessageRecoverBody(boolean requeue)
           
 MessageRejectBody createMessageRejectBody(int code, AMQShortString text)
           
 MessageResumeBody createMessageResumeBody(byte[] reference, AMQShortString identifier)
           
 MessageTransferBody createMessageTransferBody(int ticket, AMQShortString destination, boolean redelivered, boolean immediate, long ttl, short priority, long timestamp, short deliveryMode, long expiration, AMQShortString exchange, AMQShortString routingKey, AMQShortString messageId, AMQShortString correlationId, AMQShortString replyTo, AMQShortString contentType, AMQShortString contentEncoding, AMQShortString userId, AMQShortString appId, AMQShortString transactionId, byte[] securityToken, FieldTable applicationHeaders, Content body)
           
 QueueBindBody createQueueBindBody(int ticket, AMQShortString queue, AMQShortString exchange, AMQShortString routingKey, boolean nowait, FieldTable arguments)
           
 QueueBindOkBody createQueueBindOkBody()
           
 QueueDeclareBody createQueueDeclareBody(int ticket, AMQShortString queue, boolean passive, boolean durable, boolean exclusive, boolean autoDelete, boolean nowait, FieldTable arguments)
           
 QueueDeclareOkBody createQueueDeclareOkBody(AMQShortString queue, long messageCount, long consumerCount)
           
 QueueDeleteBody createQueueDeleteBody(int ticket, AMQShortString queue, boolean ifUnused, boolean ifEmpty, boolean nowait)
           
 QueueDeleteOkBody createQueueDeleteOkBody(long messageCount)
           
 QueuePurgeBody createQueuePurgeBody(int ticket, AMQShortString queue, boolean nowait)
           
 QueuePurgeOkBody createQueuePurgeOkBody(long messageCount)
           
 QueueUnbindBody createQueueUnbindBody(int ticket, AMQShortString queue, AMQShortString exchange, AMQShortString routingKey, FieldTable arguments)
           
 QueueUnbindOkBody createQueueUnbindOkBody()
           
 StreamCancelBody createStreamCancelBody(AMQShortString consumerTag, boolean nowait)
           
 StreamCancelOkBody createStreamCancelOkBody(AMQShortString consumerTag)
           
 StreamConsumeBody createStreamConsumeBody(int ticket, AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean exclusive, boolean nowait, FieldTable filter)
           
 StreamConsumeOkBody createStreamConsumeOkBody(AMQShortString consumerTag)
           
 StreamDeliverBody createStreamDeliverBody(AMQShortString consumerTag, long deliveryTag, AMQShortString exchange, AMQShortString queue)
           
 StreamPublishBody createStreamPublishBody(int ticket, AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate)
           
 StreamQosBody createStreamQosBody(long prefetchSize, int prefetchCount, long consumeRate, boolean global)
           
 StreamQosOkBody createStreamQosOkBody()
           
 StreamReturnBody createStreamReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
           
 TunnelRequestBody createTunnelRequestBody(FieldTable metaData)
           
 TxCommitBody createTxCommitBody()
           
 TxCommitOkBody createTxCommitOkBody()
           
 TxRollbackBody createTxRollbackBody()
           
 TxRollbackOkBody createTxRollbackOkBody()
           
 TxSelectBody createTxSelectBody()
           
 TxSelectOkBody createTxSelectOkBody()
           
 int getMaxClassId()
           
 int getMaxMethodId(int classId)
           
 ProtocolVersionMethodConverter getProtocolVersionMethodConverter()
           
 
Methods inherited from class org.apache.qpid.framing.MethodRegistry
getMethodRegistry
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MethodRegistry_0_9

public MethodRegistry_0_9()

MethodRegistry_0_9

public MethodRegistry_0_9(ProtocolVersion pv)
Method Detail

convertToBody

public AMQMethodBody convertToBody(org.apache.mina.common.ByteBuffer in,
                                   long size)
                            throws AMQFrameDecodingException
Specified by:
convertToBody in class MethodRegistry
Throws:
AMQFrameDecodingException

getMaxClassId

public int getMaxClassId()
Specified by:
getMaxClassId in class MethodRegistry

getMaxMethodId

public int getMaxMethodId(int classId)
Specified by:
getMaxMethodId in class MethodRegistry

createConnectionStartBody

public ConnectionStartBody createConnectionStartBody(short versionMajor,
                                                     short versionMinor,
                                                     FieldTable serverProperties,
                                                     byte[] mechanisms,
                                                     byte[] locales)
Specified by:
createConnectionStartBody in class MethodRegistry

createConnectionStartOkBody

public ConnectionStartOkBody createConnectionStartOkBody(FieldTable clientProperties,
                                                         AMQShortString mechanism,
                                                         byte[] response,
                                                         AMQShortString locale)
Specified by:
createConnectionStartOkBody in class MethodRegistry

createConnectionSecureBody

public ConnectionSecureBody createConnectionSecureBody(byte[] challenge)
Specified by:
createConnectionSecureBody in class MethodRegistry

createConnectionSecureOkBody

public ConnectionSecureOkBody createConnectionSecureOkBody(byte[] response)
Specified by:
createConnectionSecureOkBody in class MethodRegistry

createConnectionTuneBody

public ConnectionTuneBody createConnectionTuneBody(int channelMax,
                                                   long frameMax,
                                                   int heartbeat)
Specified by:
createConnectionTuneBody in class MethodRegistry

createConnectionTuneOkBody

public ConnectionTuneOkBody createConnectionTuneOkBody(int channelMax,
                                                       long frameMax,
                                                       int heartbeat)
Specified by:
createConnectionTuneOkBody in class MethodRegistry

createConnectionOpenBody

public ConnectionOpenBody createConnectionOpenBody(AMQShortString virtualHost,
                                                   AMQShortString capabilities,
                                                   boolean insist)
Specified by:
createConnectionOpenBody in class MethodRegistry

createConnectionOpenOkBody

public ConnectionOpenOkBody createConnectionOpenOkBody(AMQShortString knownHosts)
Specified by:
createConnectionOpenOkBody in class MethodRegistry

createConnectionRedirectBody

public ConnectionRedirectBody createConnectionRedirectBody(AMQShortString host,
                                                           AMQShortString knownHosts)

createConnectionCloseBody

public ConnectionCloseBody createConnectionCloseBody(int replyCode,
                                                     AMQShortString replyText,
                                                     int classId,
                                                     int methodId)
Specified by:
createConnectionCloseBody in class MethodRegistry

createConnectionCloseOkBody

public ConnectionCloseOkBody createConnectionCloseOkBody()
Specified by:
createConnectionCloseOkBody in class MethodRegistry

createChannelOpenBody

public ChannelOpenBody createChannelOpenBody(AMQShortString outOfBand)
Specified by:
createChannelOpenBody in class MethodRegistry

createChannelOpenOkBody

public ChannelOpenOkBody createChannelOpenOkBody(byte[] channelId)

createChannelFlowBody

public ChannelFlowBody createChannelFlowBody(boolean active)
Specified by:
createChannelFlowBody in class MethodRegistry

createChannelFlowOkBody

public ChannelFlowOkBody createChannelFlowOkBody(boolean active)
Specified by:
createChannelFlowOkBody in class MethodRegistry

createChannelCloseBody

public ChannelCloseBody createChannelCloseBody(int replyCode,
                                               AMQShortString replyText,
                                               int classId,
                                               int methodId)
Specified by:
createChannelCloseBody in class MethodRegistry

createChannelCloseOkBody

public ChannelCloseOkBody createChannelCloseOkBody()
Specified by:
createChannelCloseOkBody in class MethodRegistry

createChannelResumeBody

public ChannelResumeBody createChannelResumeBody(byte[] channelId)

createChannelPingBody

public ChannelPingBody createChannelPingBody()

createChannelPongBody

public ChannelPongBody createChannelPongBody()

createChannelOkBody

public ChannelOkBody createChannelOkBody()

createAccessRequestBody

public AccessRequestBody createAccessRequestBody(AMQShortString realm,
                                                 boolean exclusive,
                                                 boolean passive,
                                                 boolean active,
                                                 boolean write,
                                                 boolean read)

createAccessRequestOkBody

public AccessRequestOkBody createAccessRequestOkBody(int ticket)

createExchangeDeclareBody

public ExchangeDeclareBody createExchangeDeclareBody(int ticket,
                                                     AMQShortString exchange,
                                                     AMQShortString type,
                                                     boolean passive,
                                                     boolean durable,
                                                     boolean autoDelete,
                                                     boolean internal,
                                                     boolean nowait,
                                                     FieldTable arguments)
Specified by:
createExchangeDeclareBody in class MethodRegistry

createExchangeDeclareOkBody

public ExchangeDeclareOkBody createExchangeDeclareOkBody()
Specified by:
createExchangeDeclareOkBody in class MethodRegistry

createExchangeDeleteBody

public ExchangeDeleteBody createExchangeDeleteBody(int ticket,
                                                   AMQShortString exchange,
                                                   boolean ifUnused,
                                                   boolean nowait)
Specified by:
createExchangeDeleteBody in class MethodRegistry

createExchangeDeleteOkBody

public ExchangeDeleteOkBody createExchangeDeleteOkBody()
Specified by:
createExchangeDeleteOkBody in class MethodRegistry

createExchangeBoundBody

public ExchangeBoundBody createExchangeBoundBody(AMQShortString exchange,
                                                 AMQShortString routingKey,
                                                 AMQShortString queue)
Specified by:
createExchangeBoundBody in class MethodRegistry

createExchangeBoundOkBody

public ExchangeBoundOkBody createExchangeBoundOkBody(int replyCode,
                                                     AMQShortString replyText)
Specified by:
createExchangeBoundOkBody in class MethodRegistry

createQueueDeclareBody

public QueueDeclareBody createQueueDeclareBody(int ticket,
                                               AMQShortString queue,
                                               boolean passive,
                                               boolean durable,
                                               boolean exclusive,
                                               boolean autoDelete,
                                               boolean nowait,
                                               FieldTable arguments)
Specified by:
createQueueDeclareBody in class MethodRegistry

createQueueDeclareOkBody

public QueueDeclareOkBody createQueueDeclareOkBody(AMQShortString queue,
                                                   long messageCount,
                                                   long consumerCount)
Specified by:
createQueueDeclareOkBody in class MethodRegistry

createQueueBindBody

public QueueBindBody createQueueBindBody(int ticket,
                                         AMQShortString queue,
                                         AMQShortString exchange,
                                         AMQShortString routingKey,
                                         boolean nowait,
                                         FieldTable arguments)
Specified by:
createQueueBindBody in class MethodRegistry

createQueueBindOkBody

public QueueBindOkBody createQueueBindOkBody()
Specified by:
createQueueBindOkBody in class MethodRegistry

createQueuePurgeBody

public QueuePurgeBody createQueuePurgeBody(int ticket,
                                           AMQShortString queue,
                                           boolean nowait)
Specified by:
createQueuePurgeBody in class MethodRegistry

createQueuePurgeOkBody

public QueuePurgeOkBody createQueuePurgeOkBody(long messageCount)
Specified by:
createQueuePurgeOkBody in class MethodRegistry

createQueueDeleteBody

public QueueDeleteBody createQueueDeleteBody(int ticket,
                                             AMQShortString queue,
                                             boolean ifUnused,
                                             boolean ifEmpty,
                                             boolean nowait)
Specified by:
createQueueDeleteBody in class MethodRegistry

createQueueDeleteOkBody

public QueueDeleteOkBody createQueueDeleteOkBody(long messageCount)
Specified by:
createQueueDeleteOkBody in class MethodRegistry

createQueueUnbindBody

public QueueUnbindBody createQueueUnbindBody(int ticket,
                                             AMQShortString queue,
                                             AMQShortString exchange,
                                             AMQShortString routingKey,
                                             FieldTable arguments)

createQueueUnbindOkBody

public QueueUnbindOkBody createQueueUnbindOkBody()

createBasicQosBody

public BasicQosBody createBasicQosBody(long prefetchSize,
                                       int prefetchCount,
                                       boolean global)
Specified by:
createBasicQosBody in class MethodRegistry

createBasicQosOkBody

public BasicQosOkBody createBasicQosOkBody()
Specified by:
createBasicQosOkBody in class MethodRegistry

createBasicConsumeBody

public BasicConsumeBody createBasicConsumeBody(int ticket,
                                               AMQShortString queue,
                                               AMQShortString consumerTag,
                                               boolean noLocal,
                                               boolean noAck,
                                               boolean exclusive,
                                               boolean nowait,
                                               FieldTable arguments)
Specified by:
createBasicConsumeBody in class MethodRegistry

createBasicConsumeOkBody

public BasicConsumeOkBody createBasicConsumeOkBody(AMQShortString consumerTag)
Specified by:
createBasicConsumeOkBody in class MethodRegistry

createBasicCancelBody

public BasicCancelBody createBasicCancelBody(AMQShortString consumerTag,
                                             boolean nowait)
Specified by:
createBasicCancelBody in class MethodRegistry

createBasicCancelOkBody

public BasicCancelOkBody createBasicCancelOkBody(AMQShortString consumerTag)
Specified by:
createBasicCancelOkBody in class MethodRegistry

createBasicPublishBody

public BasicPublishBody createBasicPublishBody(int ticket,
                                               AMQShortString exchange,
                                               AMQShortString routingKey,
                                               boolean mandatory,
                                               boolean immediate)
Specified by:
createBasicPublishBody in class MethodRegistry

createBasicReturnBody

public BasicReturnBody createBasicReturnBody(int replyCode,
                                             AMQShortString replyText,
                                             AMQShortString exchange,
                                             AMQShortString routingKey)
Specified by:
createBasicReturnBody in class MethodRegistry

createBasicDeliverBody

public BasicDeliverBody createBasicDeliverBody(AMQShortString consumerTag,
                                               long deliveryTag,
                                               boolean redelivered,
                                               AMQShortString exchange,
                                               AMQShortString routingKey)
Specified by:
createBasicDeliverBody in class MethodRegistry

createBasicGetBody

public BasicGetBody createBasicGetBody(int ticket,
                                       AMQShortString queue,
                                       boolean noAck)
Specified by:
createBasicGetBody in class MethodRegistry

createBasicGetOkBody

public BasicGetOkBody createBasicGetOkBody(long deliveryTag,
                                           boolean redelivered,
                                           AMQShortString exchange,
                                           AMQShortString routingKey,
                                           long messageCount)
Specified by:
createBasicGetOkBody in class MethodRegistry

createBasicGetEmptyBody

public BasicGetEmptyBody createBasicGetEmptyBody(AMQShortString clusterId)
Specified by:
createBasicGetEmptyBody in class MethodRegistry

createBasicAckBody

public BasicAckBody createBasicAckBody(long deliveryTag,
                                       boolean multiple)
Specified by:
createBasicAckBody in class MethodRegistry

createBasicRejectBody

public BasicRejectBody createBasicRejectBody(long deliveryTag,
                                             boolean requeue)
Specified by:
createBasicRejectBody in class MethodRegistry

createBasicRecoverBody

public BasicRecoverBody createBasicRecoverBody(boolean requeue)
Specified by:
createBasicRecoverBody in class MethodRegistry

createBasicRecoverSyncOkBody

public BasicRecoverSyncOkBody createBasicRecoverSyncOkBody()

createBasicRecoverSyncBody

public BasicRecoverSyncBody createBasicRecoverSyncBody(boolean requeue)

createFileQosBody

public FileQosBody createFileQosBody(long prefetchSize,
                                     int prefetchCount,
                                     boolean global)

createFileQosOkBody

public FileQosOkBody createFileQosOkBody()

createFileConsumeBody

public FileConsumeBody createFileConsumeBody(int ticket,
                                             AMQShortString queue,
                                             AMQShortString consumerTag,
                                             boolean noLocal,
                                             boolean noAck,
                                             boolean exclusive,
                                             boolean nowait,
                                             FieldTable filter)

createFileConsumeOkBody

public FileConsumeOkBody createFileConsumeOkBody(AMQShortString consumerTag)

createFileCancelBody

public FileCancelBody createFileCancelBody(AMQShortString consumerTag,
                                           boolean nowait)

createFileCancelOkBody

public FileCancelOkBody createFileCancelOkBody(AMQShortString consumerTag)

createFileOpenBody

public FileOpenBody createFileOpenBody(AMQShortString identifier,
                                       long contentSize)

createFileOpenOkBody

public FileOpenOkBody createFileOpenOkBody(long stagedSize)

createFileStageBody

public FileStageBody createFileStageBody()

createFilePublishBody

public FilePublishBody createFilePublishBody(int ticket,
                                             AMQShortString exchange,
                                             AMQShortString routingKey,
                                             boolean mandatory,
                                             boolean immediate,
                                             AMQShortString identifier)

createFileReturnBody

public FileReturnBody createFileReturnBody(int replyCode,
                                           AMQShortString replyText,
                                           AMQShortString exchange,
                                           AMQShortString routingKey)

createFileDeliverBody

public FileDeliverBody createFileDeliverBody(AMQShortString consumerTag,
                                             long deliveryTag,
                                             boolean redelivered,
                                             AMQShortString exchange,
                                             AMQShortString routingKey,
                                             AMQShortString identifier)

createFileAckBody

public FileAckBody createFileAckBody(long deliveryTag,
                                     boolean multiple)

createFileRejectBody

public FileRejectBody createFileRejectBody(long deliveryTag,
                                           boolean requeue)

createStreamQosBody

public StreamQosBody createStreamQosBody(long prefetchSize,
                                         int prefetchCount,
                                         long consumeRate,
                                         boolean global)

createStreamQosOkBody

public StreamQosOkBody createStreamQosOkBody()

createStreamConsumeBody

public StreamConsumeBody createStreamConsumeBody(int ticket,
                                                 AMQShortString queue,
                                                 AMQShortString consumerTag,
                                                 boolean noLocal,
                                                 boolean exclusive,
                                                 boolean nowait,
                                                 FieldTable filter)

createStreamConsumeOkBody

public StreamConsumeOkBody createStreamConsumeOkBody(AMQShortString consumerTag)

createStreamCancelBody

public StreamCancelBody createStreamCancelBody(AMQShortString consumerTag,
                                               boolean nowait)

createStreamCancelOkBody

public StreamCancelOkBody createStreamCancelOkBody(AMQShortString consumerTag)

createStreamPublishBody

public StreamPublishBody createStreamPublishBody(int ticket,
                                                 AMQShortString exchange,
                                                 AMQShortString routingKey,
                                                 boolean mandatory,
                                                 boolean immediate)

createStreamReturnBody

public StreamReturnBody createStreamReturnBody(int replyCode,
                                               AMQShortString replyText,
                                               AMQShortString exchange,
                                               AMQShortString routingKey)

createStreamDeliverBody

public StreamDeliverBody createStreamDeliverBody(AMQShortString consumerTag,
                                                 long deliveryTag,
                                                 AMQShortString exchange,
                                                 AMQShortString queue)

createTxSelectBody

public TxSelectBody createTxSelectBody()
Specified by:
createTxSelectBody in class MethodRegistry

createTxSelectOkBody

public TxSelectOkBody createTxSelectOkBody()
Specified by:
createTxSelectOkBody in class MethodRegistry

createTxCommitBody

public TxCommitBody createTxCommitBody()
Specified by:
createTxCommitBody in class MethodRegistry

createTxCommitOkBody

public TxCommitOkBody createTxCommitOkBody()
Specified by:
createTxCommitOkBody in class MethodRegistry

createTxRollbackBody

public TxRollbackBody createTxRollbackBody()
Specified by:
createTxRollbackBody in class MethodRegistry

createTxRollbackOkBody

public TxRollbackOkBody createTxRollbackOkBody()
Specified by:
createTxRollbackOkBody in class MethodRegistry

createDtxSelectBody

public DtxSelectBody createDtxSelectBody()

createDtxSelectOkBody

public DtxSelectOkBody createDtxSelectOkBody()

createDtxStartBody

public DtxStartBody createDtxStartBody(AMQShortString dtxIdentifier)

createDtxStartOkBody

public DtxStartOkBody createDtxStartOkBody()

createTunnelRequestBody

public TunnelRequestBody createTunnelRequestBody(FieldTable metaData)

createMessageTransferBody

public MessageTransferBody createMessageTransferBody(int ticket,
                                                     AMQShortString destination,
                                                     boolean redelivered,
                                                     boolean immediate,
                                                     long ttl,
                                                     short priority,
                                                     long timestamp,
                                                     short deliveryMode,
                                                     long expiration,
                                                     AMQShortString exchange,
                                                     AMQShortString routingKey,
                                                     AMQShortString messageId,
                                                     AMQShortString correlationId,
                                                     AMQShortString replyTo,
                                                     AMQShortString contentType,
                                                     AMQShortString contentEncoding,
                                                     AMQShortString userId,
                                                     AMQShortString appId,
                                                     AMQShortString transactionId,
                                                     byte[] securityToken,
                                                     FieldTable applicationHeaders,
                                                     Content body)

createMessageConsumeBody

public MessageConsumeBody createMessageConsumeBody(int ticket,
                                                   AMQShortString queue,
                                                   AMQShortString destination,
                                                   boolean noLocal,
                                                   boolean noAck,
                                                   boolean exclusive,
                                                   FieldTable filter)

createMessageCancelBody

public MessageCancelBody createMessageCancelBody(AMQShortString destination)

createMessageGetBody

public MessageGetBody createMessageGetBody(int ticket,
                                           AMQShortString queue,
                                           AMQShortString destination,
                                           boolean noAck)

createMessageRecoverBody

public MessageRecoverBody createMessageRecoverBody(boolean requeue)

createMessageOpenBody

public MessageOpenBody createMessageOpenBody(byte[] reference)

createMessageCloseBody

public MessageCloseBody createMessageCloseBody(byte[] reference)

createMessageAppendBody

public MessageAppendBody createMessageAppendBody(byte[] reference,
                                                 byte[] bytes)

createMessageCheckpointBody

public MessageCheckpointBody createMessageCheckpointBody(byte[] reference,
                                                         AMQShortString identifier)

createMessageResumeBody

public MessageResumeBody createMessageResumeBody(byte[] reference,
                                                 AMQShortString identifier)

createMessageQosBody

public MessageQosBody createMessageQosBody(long prefetchSize,
                                           int prefetchCount,
                                           boolean global)

createMessageOkBody

public MessageOkBody createMessageOkBody()

createMessageEmptyBody

public MessageEmptyBody createMessageEmptyBody()

createMessageRejectBody

public MessageRejectBody createMessageRejectBody(int code,
                                                 AMQShortString text)

createMessageOffsetBody

public MessageOffsetBody createMessageOffsetBody(long value)

getProtocolVersionMethodConverter

public ProtocolVersionMethodConverter getProtocolVersionMethodConverter()
Specified by:
getProtocolVersionMethodConverter in class MethodRegistry


Licensed to the Apache Software Foundation