org.apache.qpid.framing.amqp_8_0
Class MethodRegistry_8_0
java.lang.Object
org.apache.qpid.framing.MethodRegistry
org.apache.qpid.framing.amqp_8_0.MethodRegistry_8_0
public class MethodRegistry_8_0
- extends MethodRegistry
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)
|
BasicRecoverOkBody |
createBasicRecoverOkBody()
|
BasicRejectBody |
createBasicRejectBody(long deliveryTag,
boolean requeue)
|
BasicReturnBody |
createBasicReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
ChannelAlertBody |
createChannelAlertBody(int replyCode,
AMQShortString replyText,
FieldTable details)
|
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()
|
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)
|
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()
|
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)
|
StreamCancelBody |
createStreamCancelBody(AMQShortString consumerTag,
boolean nowait)
|
StreamCancelOkBody |
createStreamCancelOkBody(AMQShortString consumerTag)
|
StreamConsumeBody |
createStreamConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean exclusive,
boolean nowait)
|
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)
|
TestContentBody |
createTestContentBody()
|
TestContentOkBody |
createTestContentOkBody(long contentChecksum)
|
TestIntegerBody |
createTestIntegerBody(short integer1,
int integer2,
long integer3,
long integer4,
short operation)
|
TestIntegerOkBody |
createTestIntegerOkBody(long result)
|
TestStringBody |
createTestStringBody(AMQShortString string1,
byte[] string2,
short operation)
|
TestStringOkBody |
createTestStringOkBody(byte[] result)
|
TestTableBody |
createTestTableBody(FieldTable table,
short integerOp,
short stringOp)
|
TestTableOkBody |
createTestTableOkBody(long integerResult,
byte[] stringResult)
|
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MethodRegistry_8_0
public MethodRegistry_8_0()
MethodRegistry_8_0
public MethodRegistry_8_0(ProtocolVersion pv)
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()
createChannelFlowBody
public ChannelFlowBody createChannelFlowBody(boolean active)
- Specified by:
createChannelFlowBody
in class MethodRegistry
createChannelFlowOkBody
public ChannelFlowOkBody createChannelFlowOkBody(boolean active)
- Specified by:
createChannelFlowOkBody
in class MethodRegistry
createChannelAlertBody
public ChannelAlertBody createChannelAlertBody(int replyCode,
AMQShortString replyText,
FieldTable details)
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
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
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
createBasicRecoverOkBody
public BasicRecoverOkBody createBasicRecoverOkBody()
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)
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)
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)
createTestIntegerBody
public TestIntegerBody createTestIntegerBody(short integer1,
int integer2,
long integer3,
long integer4,
short operation)
createTestIntegerOkBody
public TestIntegerOkBody createTestIntegerOkBody(long result)
createTestStringBody
public TestStringBody createTestStringBody(AMQShortString string1,
byte[] string2,
short operation)
createTestStringOkBody
public TestStringOkBody createTestStringOkBody(byte[] result)
createTestTableBody
public TestTableBody createTestTableBody(FieldTable table,
short integerOp,
short stringOp)
createTestTableOkBody
public TestTableOkBody createTestTableOkBody(long integerResult,
byte[] stringResult)
createTestContentBody
public TestContentBody createTestContentBody()
createTestContentOkBody
public TestContentOkBody createTestContentOkBody(long contentChecksum)
getProtocolVersionMethodConverter
public ProtocolVersionMethodConverter getProtocolVersionMethodConverter()
- Specified by:
getProtocolVersionMethodConverter
in class MethodRegistry
Licensed to the Apache Software Foundation