| Package | Description |
|---|---|
| org.apache.qpid.framing | |
| org.apache.qpid.framing.amqp_0_9 | |
| org.apache.qpid.framing.amqp_0_91 | |
| org.apache.qpid.framing.amqp_8_0 |
| Modifier and Type | Method and Description |
|---|---|
static FieldTable |
FieldTable.convertToFieldTable(Map<String,Object> map) |
FieldTable |
MessageTransferBody.getApplicationHeaders() |
FieldTable |
QueueDeclareBody.getArguments() |
FieldTable |
QueueUnbindBody.getArguments() |
FieldTable |
BasicConsumeBody.getArguments() |
FieldTable |
QueueBindBody.getArguments() |
FieldTable |
ExchangeDeclareBody.getArguments() |
FieldTable |
ConnectionStartOkBody.getClientProperties() |
FieldTable |
ChannelAlertBody.getDetails() |
FieldTable |
FieldTable.getFieldTable(AMQShortString string)
Extracts a value from the field table that is itself a FieldTable associated with the specified parameter name.
|
FieldTable |
FieldTable.getFieldTable(String string)
Extracts a value from the field table that is itself a FieldTable associated with the specified parameter name.
|
FieldTable |
MessageConsumeBody.getFilter() |
FieldTable |
BasicContentHeaderProperties.getHeaders() |
FieldTable |
TunnelRequestBody.getMetaData() |
FieldTable |
ConnectionStartBody.getServerProperties() |
FieldTable |
TestTableBody.getTable() |
static FieldTable |
FieldTableFactory.newFieldTable() |
static FieldTable |
FieldTableFactory.newFieldTable(DataInput byteBuffer,
long length) |
protected FieldTable |
AMQMethodBodyImpl.readFieldTable(DataInput buffer) |
static FieldTable |
EncodingUtils.readFieldTable(DataInput buffer) |
| Modifier and Type | Method and Description |
|---|---|
void |
FieldTable.addAll(FieldTable fieldTable) |
static Map<String,Object> |
FieldTable.convertToMap(FieldTable fieldTable) |
abstract BasicConsumeBody |
MethodRegistry.createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
abstract ConnectionStartBody |
MethodRegistry.createConnectionStartBody(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
abstract ConnectionStartOkBody |
MethodRegistry.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
abstract ExchangeDeclareBody |
MethodRegistry.createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
abstract QueueBindBody |
MethodRegistry.createQueueBindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments) |
abstract QueueDeclareBody |
MethodRegistry.createQueueDeclareBody(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
static int |
EncodingUtils.encodedFieldTableLength(FieldTable table) |
protected int |
AMQMethodBodyImpl.getSizeOf(FieldTable table) |
Object |
FieldTable.setFieldTable(AMQShortString string,
FieldTable ftValue)
Associates a nested field table with the specified parameter name.
|
Object |
FieldTable.setFieldTable(String string,
FieldTable ftValue)
Associates a nested field table with the specified parameter name.
|
void |
BasicContentHeaderProperties.setHeaders(FieldTable headers) |
protected void |
AMQMethodBodyImpl.writeFieldTable(DataOutput buffer,
FieldTable table) |
static void |
EncodingUtils.writeFieldTableBytes(DataOutput buffer,
FieldTable table) |
| Modifier and Type | Method and Description |
|---|---|
FieldTable |
MessageTransferBodyImpl.getApplicationHeaders() |
FieldTable |
QueueBindBodyImpl.getArguments() |
FieldTable |
QueueUnbindBodyImpl.getArguments() |
FieldTable |
ExchangeDeclareBodyImpl.getArguments() |
FieldTable |
QueueDeclareBodyImpl.getArguments() |
FieldTable |
BasicConsumeBodyImpl.getArguments() |
FieldTable |
ConnectionStartOkBodyImpl.getClientProperties() |
FieldTable |
FileConsumeBodyImpl.getFilter() |
FieldTable |
MessageConsumeBodyImpl.getFilter() |
FieldTable |
StreamConsumeBodyImpl.getFilter() |
FieldTable |
TunnelRequestBodyImpl.getMetaData() |
FieldTable |
ConnectionStartBodyImpl.getServerProperties() |
| Modifier and Type | Method and Description |
|---|---|
BasicConsumeBody |
MethodRegistry_0_9.createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
ConnectionStartBody |
MethodRegistry_0_9.createConnectionStartBody(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
ConnectionStartOkBody |
MethodRegistry_0_9.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
ExchangeDeclareBody |
MethodRegistry_0_9.createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
FileConsumeBody |
MethodRegistry_0_9.createFileConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable filter) |
MessageConsumeBody |
MethodRegistry_0_9.createMessageConsumeBody(int ticket,
AMQShortString queue,
AMQShortString destination,
boolean noLocal,
boolean noAck,
boolean exclusive,
FieldTable filter) |
MessageTransferBody |
MethodRegistry_0_9.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 |
MethodRegistry_0_9.createQueueBindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments) |
QueueDeclareBody |
MethodRegistry_0_9.createQueueDeclareBody(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
QueueUnbindBody |
MethodRegistry_0_9.createQueueUnbindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments) |
StreamConsumeBody |
MethodRegistry_0_9.createStreamConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean exclusive,
boolean nowait,
FieldTable filter) |
TunnelRequestBody |
MethodRegistry_0_9.createTunnelRequestBody(FieldTable metaData) |
| Constructor and Description |
|---|
BasicConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
ConnectionStartBodyImpl(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
ConnectionStartOkBodyImpl(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
ExchangeDeclareBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
FileConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable filter) |
MessageConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString destination,
boolean noLocal,
boolean noAck,
boolean exclusive,
FieldTable filter) |
MessageTransferBodyImpl(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) |
QueueBindBodyImpl(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments) |
QueueDeclareBodyImpl(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
QueueUnbindBodyImpl(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments) |
StreamConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean exclusive,
boolean nowait,
FieldTable filter) |
TunnelRequestBodyImpl(FieldTable metaData) |
| Modifier and Type | Method and Description |
|---|---|
FieldTable |
QueueBindBodyImpl.getArguments() |
FieldTable |
QueueUnbindBodyImpl.getArguments() |
FieldTable |
ExchangeDeclareBodyImpl.getArguments() |
FieldTable |
QueueDeclareBodyImpl.getArguments() |
FieldTable |
BasicConsumeBodyImpl.getArguments() |
FieldTable |
ConnectionStartOkBodyImpl.getClientProperties() |
FieldTable |
ConnectionStartBodyImpl.getServerProperties() |
| Modifier and Type | Method and Description |
|---|---|
BasicConsumeBody |
MethodRegistry_0_91.createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
ConnectionStartBody |
MethodRegistry_0_91.createConnectionStartBody(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
ConnectionStartOkBody |
MethodRegistry_0_91.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
ExchangeDeclareBody |
MethodRegistry_0_91.createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
QueueBindBody |
MethodRegistry_0_91.createQueueBindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments) |
QueueDeclareBody |
MethodRegistry_0_91.createQueueDeclareBody(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
QueueUnbindBody |
MethodRegistry_0_91.createQueueUnbindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments) |
| Constructor and Description |
|---|
BasicConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
ConnectionStartBodyImpl(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
ConnectionStartOkBodyImpl(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
ExchangeDeclareBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
QueueBindBodyImpl(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments) |
QueueDeclareBodyImpl(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
QueueUnbindBodyImpl(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments) |
| Modifier and Type | Method and Description |
|---|---|
FieldTable |
QueueBindBodyImpl.getArguments() |
FieldTable |
ExchangeDeclareBodyImpl.getArguments() |
FieldTable |
QueueDeclareBodyImpl.getArguments() |
FieldTable |
BasicConsumeBodyImpl.getArguments() |
FieldTable |
ConnectionStartOkBodyImpl.getClientProperties() |
FieldTable |
ChannelAlertBodyImpl.getDetails() |
FieldTable |
TunnelRequestBodyImpl.getMetaData() |
FieldTable |
ConnectionStartBodyImpl.getServerProperties() |
FieldTable |
TestTableBodyImpl.getTable() |
| Modifier and Type | Method and Description |
|---|---|
BasicConsumeBody |
MethodRegistry_8_0.createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
ChannelAlertBody |
MethodRegistry_8_0.createChannelAlertBody(int replyCode,
AMQShortString replyText,
FieldTable details) |
ConnectionStartBody |
MethodRegistry_8_0.createConnectionStartBody(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
ConnectionStartOkBody |
MethodRegistry_8_0.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
ExchangeDeclareBody |
MethodRegistry_8_0.createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
QueueBindBody |
MethodRegistry_8_0.createQueueBindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments) |
QueueDeclareBody |
MethodRegistry_8_0.createQueueDeclareBody(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
TestTableBody |
MethodRegistry_8_0.createTestTableBody(FieldTable table,
short integerOp,
short stringOp) |
TunnelRequestBody |
MethodRegistry_8_0.createTunnelRequestBody(FieldTable metaData) |
| Constructor and Description |
|---|
BasicConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
ChannelAlertBodyImpl(int replyCode,
AMQShortString replyText,
FieldTable details) |
ConnectionStartBodyImpl(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
ConnectionStartOkBodyImpl(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
ExchangeDeclareBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
QueueBindBodyImpl(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments) |
QueueDeclareBodyImpl(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
TestTableBodyImpl(FieldTable table,
short integerOp,
short stringOp) |
TunnelRequestBodyImpl(FieldTable metaData) |
Copyright © 2006–2014 The Apache Software Foundation. All rights reserved.