org.apache.qpid.framing

Class MethodRegistry

java.lang.Object

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

Fields

Modifier and Type	Field and Description
static MethodRegistry	registry_0_9
static MethodRegistry	registry_0_91
static MethodRegistry	registry_8_0

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MethodRegistry(ProtocolVersion pv)

Method Summary

Methods

Modifier and Type	Method and Description
abstract AMQMethodBody	convertToBody(MarkableDataInput 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(MarkableDataInput in,
                          long size)
                                     throws AMQFrameDecodingException,
                                            IOException

Throws:

AMQFrameDecodingException

IOException

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()