org.apache.qpid.framing.amqp_0_91
Class MethodRegistry_0_91

java.lang.Object
  extended by org.apache.qpid.framing.MethodRegistry
      extended by org.apache.qpid.framing.amqp_0_91.MethodRegistry_0_91

public class MethodRegistry_0_91
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_91()
           
MethodRegistry_0_91(ProtocolVersion pv)
           
 
Method Summary
 AMQMethodBody convertToBody(org.apache.mina.common.ByteBuffer in, long size)
           
 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)
           
 ChannelOpenBody createChannelOpenBody(AMQShortString outOfBand)
           
 ChannelOpenOkBody createChannelOpenOkBody(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)
           
 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)
           
 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()
           
 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()
           
 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_91

public MethodRegistry_0_91()

MethodRegistry_0_91

public MethodRegistry_0_91(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

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

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

createBasicRecoverSyncBody

public BasicRecoverSyncBody createBasicRecoverSyncBody(boolean requeue)

createBasicRecoverSyncOkBody

public BasicRecoverSyncOkBody createBasicRecoverSyncOkBody()

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

getProtocolVersionMethodConverter

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


Licensed to the Apache Software Foundation