Package | Description |
---|---|
org.apache.qpid.client.message | |
org.apache.qpid.client.protocol | |
org.apache.qpid.framing | |
org.apache.qpid.server.protocol.v0_8 | |
org.apache.qpid.server.store.berkeleydb |
Constructor and Description |
---|
JMSHeaderAdapter(FieldTable headers) |
Modifier and Type | Method and Description |
---|---|
FieldTable |
AMQProtocolSession.getConnectionStartServerProperties() |
Modifier and Type | Method and Description |
---|---|
void |
AMQProtocolSession.setConnectionStartServerProperties(FieldTable serverProperties) |
Modifier and Type | Method and Description |
---|---|
static FieldTable |
FieldTable.convertToFieldTable(Map<String,Object> map) |
FieldTable |
QueueBindBody.getArguments() |
FieldTable |
QueueDeclareBody.getArguments() |
FieldTable |
QueueUnbindBody.getArguments() |
FieldTable |
BasicConsumeBody.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 |
BasicContentHeaderProperties.getHeaders() |
FieldTable |
ConnectionStartBody.getServerProperties() |
static FieldTable |
FieldTableFactory.newFieldTable() |
static FieldTable |
EncodingUtils.readFieldTable(MarkableDataInput input) |
Modifier and Type | Method and Description |
---|---|
void |
FieldTable.addAll(FieldTable fieldTable) |
static Map<String,Object> |
FieldTable.convertToMap(FieldTable fieldTable) |
ChannelAlertBody |
MethodRegistry.createChannelAlertBody(int replyCode,
AMQShortString replyText,
FieldTable details) |
ConnectionStartBody |
MethodRegistry.createConnectionStartBody(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
ConnectionStartOkBody |
MethodRegistry.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
QueueUnbindBody |
MethodRegistry.createQueueUnbindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments) |
static int |
EncodingUtils.encodedFieldTableLength(FieldTable table) |
protected int |
AMQMethodBodyImpl.getSizeOf(FieldTable table) |
void |
ServerChannelMethodProcessor.receiveBasicConsume(AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
void |
ClientChannelMethodProcessor.receiveChannelAlert(int replyCode,
AMQShortString replyText,
FieldTable details) |
void |
FrameCreatingMethodProcessor.receiveConnectionStart(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
void |
ClientMethodProcessor.receiveConnectionStart(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
void |
FrameCreatingMethodProcessor.receiveConnectionStartOk(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
void |
ServerMethodProcessor.receiveConnectionStartOk(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
void |
ServerChannelMethodProcessor.receiveExchangeDeclare(AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
void |
ServerChannelMethodProcessor.receiveQueueBind(AMQShortString queue,
AMQShortString exchange,
AMQShortString bindingKey,
boolean nowait,
FieldTable arguments) |
void |
ServerChannelMethodProcessor.receiveQueueDeclare(AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
void |
ServerChannelMethodProcessor.receiveQueueUnbind(AMQShortString queue,
AMQShortString exchange,
AMQShortString bindingKey,
FieldTable arguments) |
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) |
Constructor and Description |
---|
BasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
ChannelAlertBody(int replyCode,
AMQShortString replyText,
FieldTable details) |
ConnectionStartBody(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales) |
ConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
ExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
FieldTable(FieldTable other) |
QueueBindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments) |
QueueDeclareBody(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
QueueUnbindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments) |
Modifier and Type | Method and Description |
---|---|
AMQShortString |
AMQChannel.consumeFromSource(AMQShortString tag,
Collection<MessageSource> sources,
boolean acks,
FieldTable arguments,
boolean exclusive,
boolean noLocal)
Subscribe to a queue.
|
static ConsumerTarget_0_8 |
ConsumerTarget_0_8.createAckTarget(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager) |
static ConsumerTarget_0_8 |
ConsumerTarget_0_8.createAckTarget(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod) |
static ConsumerTarget_0_8 |
ConsumerTarget_0_8.createBrowserTarget(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager) |
static ConsumerTarget_0_8 |
ConsumerTarget_0_8.createGetNoAckTarget(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod) |
static ConsumerTarget_0_8 |
ConsumerTarget_0_8.createNoAckTarget(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager) |
static ConsumerTarget_0_8 |
ConsumerTarget_0_8.createNoAckTarget(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod) |
void |
AMQChannel.receiveBasicConsume(AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
void |
AMQPConnection_0_8.receiveConnectionStartOk(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
void |
AMQChannel.receiveExchangeDeclare(AMQShortString exchangeName,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
void |
AMQChannel.receiveQueueBind(AMQShortString queueName,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable argumentsTable) |
void |
AMQChannel.receiveQueueDeclare(AMQShortString queueStr,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
void |
AMQChannel.receiveQueueUnbind(AMQShortString queueName,
AMQShortString exchange,
AMQShortString bindingKey,
FieldTable arguments) |
Constructor and Description |
---|
ConsumerTarget_0_8(AMQChannel channel,
AMQShortString consumerTag,
FieldTable arguments,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod) |
GetNoAckConsumer(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod) |
NoAckConsumer(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod) |
Modifier and Type | Method and Description |
---|---|
static FieldTable |
FieldTableEncoding.readFieldTable(com.sleepycat.bind.tuple.TupleInput tupleInput) |
Modifier and Type | Method and Description |
---|---|
static void |
FieldTableEncoding.writeFieldTable(FieldTable fieldTable,
com.sleepycat.bind.tuple.TupleOutput tupleOutput) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.