org.apache.qpid.framing
Class MethodRegistry

java.lang.Object
  extended by org.apache.qpid.framing.MethodRegistry
Direct Known Subclasses:
MethodRegistry_0_9, MethodRegistry_0_91, MethodRegistry_8_0

public abstract class MethodRegistry
extends Object


Field Summary
static MethodRegistry registry_0_9
           
static MethodRegistry registry_0_91
           
static MethodRegistry registry_8_0
           
 
Constructor Summary
protected MethodRegistry(ProtocolVersion pv)
           
 
Method Summary
abstract  AMQMethodBody convertToBody(org.apache.mina.common.ByteBuffer in, long size)
           
abstract  BasicAckBody createBasicAckBody(long deliveryTag, boolean multiple)
           
abstract  BasicCancelBody createBasicCancelBody(AMQShortString consumerTag, boolean nowait)
           
abstract  BasicCancelOkBody createBasicCancelOkBody(AMQShortString consumerTag)
           
abstract  BasicConsumeBody createBasicConsumeBody(int ticket, AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, FieldTable arguments)
           
abstract  BasicConsumeOkBody createBasicConsumeOkBody(AMQShortString consumerTag)
           
abstract  BasicDeliverBody createBasicDeliverBody(AMQShortString consumerTag, long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey)
           
abstract  BasicGetBody createBasicGetBody(int ticket, AMQShortString queue, boolean noAck)
           
abstract  BasicGetEmptyBody createBasicGetEmptyBody(AMQShortString clusterId)
           
abstract  BasicGetOkBody createBasicGetOkBody(long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey, long messageCount)
           
abstract  BasicPublishBody createBasicPublishBody(int ticket, AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate)
           
abstract  BasicQosBody createBasicQosBody(long prefetchSize, int prefetchCount, boolean global)
           
abstract  BasicQosOkBody createBasicQosOkBody()
           
abstract  BasicRecoverBody createBasicRecoverBody(boolean requeue)
           
abstract  BasicRejectBody createBasicRejectBody(long deliveryTag, boolean requeue)
           
abstract  BasicReturnBody createBasicReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
           
abstract  ChannelCloseBody createChannelCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
           
abstract  ChannelCloseOkBody createChannelCloseOkBody()
           
abstract  ChannelFlowBody createChannelFlowBody(boolean active)
           
abstract  ChannelFlowOkBody createChannelFlowOkBody(boolean active)
           
abstract  ChannelOpenBody createChannelOpenBody(AMQShortString outOfBand)
           
abstract  ConnectionCloseBody createConnectionCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
           
abstract  ConnectionCloseOkBody createConnectionCloseOkBody()
           
abstract  ConnectionOpenBody createConnectionOpenBody(AMQShortString virtualHost, AMQShortString capabilities, boolean insist)
           
abstract  ConnectionOpenOkBody createConnectionOpenOkBody(AMQShortString knownHosts)
           
abstract  ConnectionSecureBody createConnectionSecureBody(byte[] challenge)
           
abstract  ConnectionSecureOkBody createConnectionSecureOkBody(byte[] response)
           
abstract  ConnectionStartBody createConnectionStartBody(short versionMajor, short versionMinor, FieldTable serverProperties, byte[] mechanisms, byte[] locales)
           
abstract  ConnectionStartOkBody createConnectionStartOkBody(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
           
abstract  ConnectionTuneBody createConnectionTuneBody(int channelMax, long frameMax, int heartbeat)
           
abstract  ConnectionTuneOkBody createConnectionTuneOkBody(int channelMax, long frameMax, int heartbeat)
           
abstract  ExchangeBoundBody createExchangeBoundBody(AMQShortString exchange, AMQShortString routingKey, AMQShortString queue)
           
abstract  ExchangeBoundOkBody createExchangeBoundOkBody(int replyCode, AMQShortString replyText)
           
abstract  ExchangeDeclareBody createExchangeDeclareBody(int ticket, AMQShortString exchange, AMQShortString type, boolean passive, boolean durable, boolean autoDelete, boolean internal, boolean nowait, FieldTable arguments)
           
abstract  ExchangeDeclareOkBody createExchangeDeclareOkBody()
           
abstract  ExchangeDeleteBody createExchangeDeleteBody(int ticket, AMQShortString exchange, boolean ifUnused, boolean nowait)
           
abstract  ExchangeDeleteOkBody createExchangeDeleteOkBody()
           
abstract  QueueBindBody createQueueBindBody(int ticket, AMQShortString queue, AMQShortString exchange, AMQShortString routingKey, boolean nowait, FieldTable arguments)
           
abstract  QueueBindOkBody createQueueBindOkBody()
           
abstract  QueueDeclareBody createQueueDeclareBody(int ticket, AMQShortString queue, boolean passive, boolean durable, boolean exclusive, boolean autoDelete, boolean nowait, FieldTable arguments)
           
abstract  QueueDeclareOkBody createQueueDeclareOkBody(AMQShortString queue, long messageCount, long consumerCount)
           
abstract  QueueDeleteBody createQueueDeleteBody(int ticket, AMQShortString queue, boolean ifUnused, boolean ifEmpty, boolean nowait)
           
abstract  QueueDeleteOkBody createQueueDeleteOkBody(long messageCount)
           
abstract  QueuePurgeBody createQueuePurgeBody(int ticket, AMQShortString queue, boolean nowait)
           
abstract  QueuePurgeOkBody createQueuePurgeOkBody(long messageCount)
           
abstract  TxCommitBody createTxCommitBody()
           
abstract  TxCommitOkBody createTxCommitOkBody()
           
abstract  TxRollbackBody createTxRollbackBody()
           
abstract  TxRollbackOkBody createTxRollbackOkBody()
           
abstract  TxSelectBody createTxSelectBody()
           
abstract  TxSelectOkBody createTxSelectOkBody()
           
abstract  int getMaxClassId()
           
abstract  int getMaxMethodId(int classId)
           
static MethodRegistry getMethodRegistry(ProtocolVersion pv)
           
abstract  ProtocolVersionMethodConverter getProtocolVersionMethodConverter()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

registry_0_9

public static final MethodRegistry registry_0_9

registry_0_91

public static final MethodRegistry registry_0_91

registry_8_0

public static final MethodRegistry registry_8_0
Constructor Detail

MethodRegistry

protected MethodRegistry(ProtocolVersion pv)
Method Detail

convertToBody

public abstract AMQMethodBody convertToBody(org.apache.mina.common.ByteBuffer in,
                                            long size)
                                     throws AMQFrameDecodingException
Throws:
AMQFrameDecodingException

getMaxClassId

public abstract int getMaxClassId()

getMaxMethodId

public abstract int getMaxMethodId(int classId)

getMethodRegistry

public static MethodRegistry getMethodRegistry(ProtocolVersion pv)

createBasicAckBody

public abstract BasicAckBody createBasicAckBody(long deliveryTag,
                                                boolean multiple)

createBasicCancelBody

public abstract BasicCancelBody createBasicCancelBody(AMQShortString consumerTag,
                                                      boolean nowait)

createBasicCancelOkBody

public abstract BasicCancelOkBody createBasicCancelOkBody(AMQShortString consumerTag)

createBasicConsumeBody

public abstract BasicConsumeBody createBasicConsumeBody(int ticket,
                                                        AMQShortString queue,
                                                        AMQShortString consumerTag,
                                                        boolean noLocal,
                                                        boolean noAck,
                                                        boolean exclusive,
                                                        boolean nowait,
                                                        FieldTable arguments)

createBasicConsumeOkBody

public abstract BasicConsumeOkBody createBasicConsumeOkBody(AMQShortString consumerTag)

createBasicDeliverBody

public abstract BasicDeliverBody createBasicDeliverBody(AMQShortString consumerTag,
                                                        long deliveryTag,
                                                        boolean redelivered,
                                                        AMQShortString exchange,
                                                        AMQShortString routingKey)

createBasicGetBody

public abstract BasicGetBody createBasicGetBody(int ticket,
                                                AMQShortString queue,
                                                boolean noAck)

createBasicGetEmptyBody

public abstract BasicGetEmptyBody createBasicGetEmptyBody(AMQShortString clusterId)

createBasicGetOkBody

public abstract BasicGetOkBody createBasicGetOkBody(long deliveryTag,
                                                    boolean redelivered,
                                                    AMQShortString exchange,
                                                    AMQShortString routingKey,
                                                    long messageCount)

createBasicPublishBody

public abstract BasicPublishBody createBasicPublishBody(int ticket,
                                                        AMQShortString exchange,
                                                        AMQShortString routingKey,
                                                        boolean mandatory,
                                                        boolean immediate)

createBasicQosBody

public abstract BasicQosBody createBasicQosBody(long prefetchSize,
                                                int prefetchCount,
                                                boolean global)

createBasicQosOkBody

public abstract BasicQosOkBody createBasicQosOkBody()

createBasicRecoverBody

public abstract BasicRecoverBody createBasicRecoverBody(boolean requeue)

createBasicRejectBody

public abstract BasicRejectBody createBasicRejectBody(long deliveryTag,
                                                      boolean requeue)

createBasicReturnBody

public abstract BasicReturnBody createBasicReturnBody(int replyCode,
                                                      AMQShortString replyText,
                                                      AMQShortString exchange,
                                                      AMQShortString routingKey)

createChannelCloseBody

public abstract ChannelCloseBody createChannelCloseBody(int replyCode,
                                                        AMQShortString replyText,
                                                        int classId,
                                                        int methodId)

createChannelCloseOkBody

public abstract ChannelCloseOkBody createChannelCloseOkBody()

createChannelFlowBody

public abstract ChannelFlowBody createChannelFlowBody(boolean active)

createChannelFlowOkBody

public abstract ChannelFlowOkBody createChannelFlowOkBody(boolean active)

createChannelOpenBody

public abstract ChannelOpenBody createChannelOpenBody(AMQShortString outOfBand)

createConnectionCloseBody

public abstract ConnectionCloseBody createConnectionCloseBody(int replyCode,
                                                              AMQShortString replyText,
                                                              int classId,
                                                              int methodId)

createConnectionCloseOkBody

public abstract ConnectionCloseOkBody createConnectionCloseOkBody()

createConnectionOpenBody

public abstract ConnectionOpenBody createConnectionOpenBody(AMQShortString virtualHost,
                                                            AMQShortString capabilities,
                                                            boolean insist)

createConnectionOpenOkBody

public abstract ConnectionOpenOkBody createConnectionOpenOkBody(AMQShortString knownHosts)

createConnectionSecureBody

public abstract ConnectionSecureBody createConnectionSecureBody(byte[] challenge)

createConnectionSecureOkBody

public abstract ConnectionSecureOkBody createConnectionSecureOkBody(byte[] response)

createConnectionStartBody

public abstract ConnectionStartBody createConnectionStartBody(short versionMajor,
                                                              short versionMinor,
                                                              FieldTable serverProperties,
                                                              byte[] mechanisms,
                                                              byte[] locales)

createConnectionStartOkBody

public abstract ConnectionStartOkBody createConnectionStartOkBody(FieldTable clientProperties,
                                                                  AMQShortString mechanism,
                                                                  byte[] response,
                                                                  AMQShortString locale)

createConnectionTuneBody

public abstract ConnectionTuneBody createConnectionTuneBody(int channelMax,
                                                            long frameMax,
                                                            int heartbeat)

createConnectionTuneOkBody

public abstract ConnectionTuneOkBody createConnectionTuneOkBody(int channelMax,
                                                                long frameMax,
                                                                int heartbeat)

createExchangeBoundBody

public abstract ExchangeBoundBody createExchangeBoundBody(AMQShortString exchange,
                                                          AMQShortString routingKey,
                                                          AMQShortString queue)

createExchangeBoundOkBody

public abstract ExchangeBoundOkBody createExchangeBoundOkBody(int replyCode,
                                                              AMQShortString replyText)

createExchangeDeclareBody

public abstract ExchangeDeclareBody createExchangeDeclareBody(int ticket,
                                                              AMQShortString exchange,
                                                              AMQShortString type,
                                                              boolean passive,
                                                              boolean durable,
                                                              boolean autoDelete,
                                                              boolean internal,
                                                              boolean nowait,
                                                              FieldTable arguments)

createExchangeDeclareOkBody

public abstract ExchangeDeclareOkBody createExchangeDeclareOkBody()

createExchangeDeleteBody

public abstract ExchangeDeleteBody createExchangeDeleteBody(int ticket,
                                                            AMQShortString exchange,
                                                            boolean ifUnused,
                                                            boolean nowait)

createExchangeDeleteOkBody

public abstract ExchangeDeleteOkBody createExchangeDeleteOkBody()

createQueueBindBody

public abstract QueueBindBody createQueueBindBody(int ticket,
                                                  AMQShortString queue,
                                                  AMQShortString exchange,
                                                  AMQShortString routingKey,
                                                  boolean nowait,
                                                  FieldTable arguments)

createQueueBindOkBody

public abstract QueueBindOkBody createQueueBindOkBody()

createQueueDeclareBody

public abstract QueueDeclareBody createQueueDeclareBody(int ticket,
                                                        AMQShortString queue,
                                                        boolean passive,
                                                        boolean durable,
                                                        boolean exclusive,
                                                        boolean autoDelete,
                                                        boolean nowait,
                                                        FieldTable arguments)

createQueueDeclareOkBody

public abstract QueueDeclareOkBody createQueueDeclareOkBody(AMQShortString queue,
                                                            long messageCount,
                                                            long consumerCount)

createQueueDeleteBody

public abstract QueueDeleteBody createQueueDeleteBody(int ticket,
                                                      AMQShortString queue,
                                                      boolean ifUnused,
                                                      boolean ifEmpty,
                                                      boolean nowait)

createQueueDeleteOkBody

public abstract QueueDeleteOkBody createQueueDeleteOkBody(long messageCount)

createQueuePurgeBody

public abstract QueuePurgeBody createQueuePurgeBody(int ticket,
                                                    AMQShortString queue,
                                                    boolean nowait)

createQueuePurgeOkBody

public abstract QueuePurgeOkBody createQueuePurgeOkBody(long messageCount)

createTxCommitBody

public abstract TxCommitBody createTxCommitBody()

createTxCommitOkBody

public abstract TxCommitOkBody createTxCommitOkBody()

createTxRollbackBody

public abstract TxRollbackBody createTxRollbackBody()

createTxRollbackOkBody

public abstract TxRollbackOkBody createTxRollbackOkBody()

createTxSelectBody

public abstract TxSelectBody createTxSelectBody()

createTxSelectOkBody

public abstract TxSelectOkBody createTxSelectOkBody()

getProtocolVersionMethodConverter

public abstract ProtocolVersionMethodConverter getProtocolVersionMethodConverter()


Licensed to the Apache Software Foundation