Modifier and Type | Method and Description |
---|---|
AMQShortString |
AMQDestination.getEncodedName() |
AMQShortString |
CustomJMSXProperty.getShortStringName() |
Modifier and Type | Method and Description |
---|---|
AMQShortString |
UnprocessedMessage_0_8.getExchange() |
AMQShortString |
ReturnMessage.getReplyText() |
AMQShortString |
UnprocessedMessage_0_8.getRoutingKey() |
Constructor and Description |
---|
ReturnMessage(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString replyText,
int replyCode) |
UnprocessedMessage_0_8(long deliveryId,
int consumerTag,
AMQShortString exchange,
AMQShortString routingKey,
boolean redelivered) |
Modifier and Type | Method and Description |
---|---|
void |
AMQProtocolSession.confirmConsumerCancelled(int channelId,
AMQShortString consumerTag) |
Modifier and Type | Method and Description |
---|---|
AMQShortString |
MarkableDataInput.readAMQShortString() |
Modifier and Type | Field and Description |
---|---|
static AMQShortString |
AMQShortString.EMPTY_STRING |
Modifier and Type | Method and Description |
---|---|
Iterator<Map.Entry<AMQShortString,AMQTypedValue>> |
FieldTable.iterator() |
Set<AMQShortString> |
FieldTable.keySet() |
Modifier and Type | Method and Description |
---|---|
protected static void |
FieldTable.checkIdentiferFormat(AMQShortString propertyName) |
int |
AMQShortString.compareTo(AMQShortString name) |
boolean |
FieldTable.containsKey(AMQShortString key) |
AccessRequestBody |
MethodRegistry.createAccessRequestBody(AMQShortString realm,
boolean exclusive,
boolean passive,
boolean active,
boolean write,
boolean read) |
BasicCancelBody |
MethodRegistry.createBasicCancelBody(AMQShortString consumerTag,
boolean nowait) |
BasicCancelOkBody |
MethodRegistry.createBasicCancelOkBody(AMQShortString consumerTag) |
BasicConsumeOkBody |
MethodRegistry.createBasicConsumeOkBody(AMQShortString consumerTag) |
BasicDeliverBody |
MethodRegistry.createBasicDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey) |
BasicGetBody |
MethodRegistry.createBasicGetBody(int ticket,
AMQShortString queue,
boolean noAck) |
BasicGetEmptyBody |
MethodRegistry.createBasicGetEmptyBody(AMQShortString clusterId) |
BasicGetOkBody |
MethodRegistry.createBasicGetOkBody(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount) |
BasicReturnBody |
MethodRegistry.createBasicReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey) |
ChannelAlertBody |
MethodRegistry.createChannelAlertBody(int replyCode,
AMQShortString replyText,
FieldTable details) |
ChannelCloseBody |
MethodRegistry.createChannelCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId) |
ChannelOpenBody |
MethodRegistry.createChannelOpenBody(AMQShortString outOfBand) |
ConnectionCloseBody |
MethodRegistry.createConnectionCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId) |
ConnectionOpenBody |
MethodRegistry.createConnectionOpenBody(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist) |
ConnectionOpenOkBody |
MethodRegistry.createConnectionOpenOkBody(AMQShortString knownHosts) |
ConnectionRedirectBody |
MethodRegistry.createConnectionRedirectBody(AMQShortString host,
AMQShortString knownHosts) |
ConnectionStartOkBody |
MethodRegistry.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
ExchangeBoundOkBody |
MethodRegistry.createExchangeBoundOkBody(int replyCode,
AMQShortString replyText) |
QueueDeclareOkBody |
MethodRegistry.createQueueDeclareOkBody(AMQShortString queue,
long messageCount,
long consumerCount) |
QueuePurgeBody |
MethodRegistry.createQueuePurgeBody(int ticket,
AMQShortString queue,
boolean nowait) |
QueueUnbindBody |
MethodRegistry.createQueueUnbindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments) |
static int |
EncodingUtils.encodedShortStringLength(AMQShortString s) |
boolean |
AMQShortString.equals(AMQShortString otherString) |
Object |
FieldTable.get(AMQShortString key) |
Boolean |
FieldTable.getBoolean(AMQShortString string) |
Byte |
FieldTable.getByte(AMQShortString string) |
byte[] |
FieldTable.getBytes(AMQShortString string) |
Character |
FieldTable.getCharacter(AMQShortString string) |
BigDecimal |
FieldTable.getDecimal(AMQShortString propertyName) |
Double |
FieldTable.getDouble(AMQShortString string) |
FieldTable |
FieldTable.getFieldTable(AMQShortString string)
Extracts a value from the field table that is itself a FieldTable associated with the specified parameter name.
|
Float |
FieldTable.getFloat(AMQShortString string) |
Integer |
FieldTable.getInteger(AMQShortString string) |
Long |
FieldTable.getLong(AMQShortString string) |
Object |
FieldTable.getObject(AMQShortString string) |
AMQTypedValue |
FieldTable.getProperty(AMQShortString string) |
Short |
FieldTable.getShort(AMQShortString string) |
protected int |
AMQMethodBodyImpl.getSizeOf(AMQShortString string) |
String |
FieldTable.getString(AMQShortString string) |
Long |
FieldTable.getTimestamp(AMQShortString name) |
boolean |
FieldTable.itemExists(AMQShortString propertyName) |
boolean |
FieldTable.propertyExists(AMQShortString propertyName) |
Object |
FieldTable.put(AMQShortString key,
Object value) |
void |
ServerChannelMethodProcessor.receiveAccessRequest(AMQShortString realm,
boolean exclusive,
boolean passive,
boolean active,
boolean write,
boolean read) |
void |
ServerChannelMethodProcessor.receiveBasicCancel(AMQShortString consumerTag,
boolean noWait) |
void |
ClientChannelMethodProcessor.receiveBasicCancelOk(AMQShortString consumerTag) |
void |
ServerChannelMethodProcessor.receiveBasicConsume(AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
void |
ClientChannelMethodProcessor.receiveBasicConsumeOk(AMQShortString consumerTag) |
void |
ClientChannelMethodProcessor.receiveBasicDeliver(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey) |
void |
ServerChannelMethodProcessor.receiveBasicGet(AMQShortString queue,
boolean noAck) |
void |
ClientChannelMethodProcessor.receiveBasicGetOk(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount) |
void |
ServerChannelMethodProcessor.receiveBasicPublish(AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate) |
void |
ClientChannelMethodProcessor.receiveBasicReturn(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey) |
void |
ClientChannelMethodProcessor.receiveChannelAlert(int replyCode,
AMQShortString replyText,
FieldTable details) |
void |
ChannelMethodProcessor.receiveChannelClose(int replyCode,
AMQShortString replyText,
int classId,
int methodId) |
void |
FrameCreatingMethodProcessor.receiveConnectionClose(int replyCode,
AMQShortString replyText,
int classId,
int methodId) |
void |
MethodProcessor.receiveConnectionClose(int replyCode,
AMQShortString replyText,
int classId,
int methodId) |
void |
FrameCreatingMethodProcessor.receiveConnectionOpen(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist) |
void |
ServerMethodProcessor.receiveConnectionOpen(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist) |
void |
FrameCreatingMethodProcessor.receiveConnectionOpenOk(AMQShortString knownHosts) |
void |
ClientMethodProcessor.receiveConnectionOpenOk(AMQShortString knownHosts) |
void |
FrameCreatingMethodProcessor.receiveConnectionRedirect(AMQShortString host,
AMQShortString knownHosts) |
void |
ClientMethodProcessor.receiveConnectionRedirect(AMQShortString host,
AMQShortString knownHosts) |
void |
FrameCreatingMethodProcessor.receiveConnectionStartOk(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
void |
ServerMethodProcessor.receiveConnectionStartOk(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
void |
ServerChannelMethodProcessor.receiveExchangeBound(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue) |
void |
ClientChannelMethodProcessor.receiveExchangeBoundOk(int replyCode,
AMQShortString replyText) |
void |
ServerChannelMethodProcessor.receiveExchangeDeclare(AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
void |
ServerChannelMethodProcessor.receiveExchangeDelete(AMQShortString exchange,
boolean ifUnused,
boolean nowait) |
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 |
ClientChannelMethodProcessor.receiveQueueDeclareOk(AMQShortString queue,
long messageCount,
long consumerCount) |
void |
ServerChannelMethodProcessor.receiveQueueDelete(AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait) |
void |
ServerChannelMethodProcessor.receiveQueuePurge(AMQShortString queue,
boolean nowait) |
void |
ServerChannelMethodProcessor.receiveQueueUnbind(AMQShortString queue,
AMQShortString exchange,
AMQShortString bindingKey,
FieldTable arguments) |
Object |
FieldTable.remove(AMQShortString key) |
AMQTypedValue |
FieldTable.removeKey(AMQShortString key) |
void |
BasicContentHeaderProperties.setAppId(AMQShortString appId) |
Object |
FieldTable.setAsciiString(AMQShortString string,
String value) |
Object |
FieldTable.setBoolean(AMQShortString string,
Boolean b) |
Object |
FieldTable.setByte(AMQShortString string,
Byte b) |
Object |
FieldTable.setBytes(AMQShortString string,
byte[] bytes) |
Object |
FieldTable.setBytes(AMQShortString string,
byte[] bytes,
int start,
int length) |
Object |
FieldTable.setChar(AMQShortString string,
char c) |
void |
BasicContentHeaderProperties.setClusterId(AMQShortString clusterId) |
void |
BasicContentHeaderProperties.setContentType(AMQShortString contentType) |
void |
BasicContentHeaderProperties.setCorrelationId(AMQShortString correlationId) |
Object |
FieldTable.setDecimal(AMQShortString string,
BigDecimal decimal) |
Object |
FieldTable.setDouble(AMQShortString string,
Double v) |
void |
BasicContentHeaderProperties.setEncoding(AMQShortString encoding) |
void |
MessagePublishInfo.setExchange(AMQShortString exchange) |
Object |
FieldTable.setFieldArray(AMQShortString string,
Collection<?> collection) |
Object |
FieldTable.setFieldTable(AMQShortString string,
FieldTable ftValue)
Associates a nested field table with the specified parameter name.
|
Object |
FieldTable.setFloat(AMQShortString string,
Float v) |
Object |
FieldTable.setInteger(AMQShortString string,
int i) |
Object |
FieldTable.setLong(AMQShortString string,
long l) |
void |
BasicContentHeaderProperties.setMessageId(AMQShortString messageId) |
Object |
FieldTable.setObject(AMQShortString string,
Object object) |
void |
BasicContentHeaderProperties.setReplyTo(AMQShortString replyTo) |
void |
MessagePublishInfo.setRoutingKey(AMQShortString routingKey) |
Object |
FieldTable.setShort(AMQShortString string,
Short i) |
Object |
FieldTable.setString(AMQShortString string,
String value) |
Object |
FieldTable.setTimestamp(AMQShortString string,
long datetime) |
void |
BasicContentHeaderProperties.setType(AMQShortString type) |
void |
BasicContentHeaderProperties.setUserId(AMQShortString userId) |
Object |
FieldTable.setVoid(AMQShortString string) |
static String |
AMQShortString.toString(AMQShortString amqShortString) |
protected void |
AMQMethodBodyImpl.writeAMQShortString(DataOutput buffer,
AMQShortString string) |
static void |
EncodingUtils.writeShortStringBytes(DataOutput buffer,
AMQShortString s) |
static void |
EncodingUtils.writeShortStringBytes(QpidByteBuffer buffer,
AMQShortString s) |
Constructor and Description |
---|
AccessRequestBody(AMQShortString realm,
boolean exclusive,
boolean passive,
boolean active,
boolean write,
boolean read) |
BasicCancelBody(AMQShortString consumerTag,
boolean nowait) |
BasicCancelOkBody(AMQShortString consumerTag) |
BasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
BasicConsumeOkBody(AMQShortString consumerTag) |
BasicDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey) |
BasicGetBody(int ticket,
AMQShortString queue,
boolean noAck) |
BasicGetEmptyBody(AMQShortString clusterId) |
BasicGetOkBody(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount) |
BasicPublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate) |
BasicReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey) |
ChannelAlertBody(int replyCode,
AMQShortString replyText,
FieldTable details) |
ChannelCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId) |
ConnectionCloseBody(ProtocolVersion protocolVersion,
int replyCode,
AMQShortString replyText,
int classId,
int methodId) |
ConnectionOpenBody(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist) |
ConnectionOpenOkBody(AMQShortString knownHosts) |
ConnectionRedirectBody(ProtocolVersion protocolVersion,
AMQShortString host,
AMQShortString knownHosts) |
ConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
ExchangeBoundBody(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue) |
ExchangeBoundOkBody(int replyCode,
AMQShortString replyText) |
ExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
ExchangeDeleteBody(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait) |
MessagePublishInfo(AMQShortString exchange,
boolean immediate,
boolean mandatory,
AMQShortString routingKey) |
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) |
QueueDeclareOkBody(AMQShortString queue,
long messageCount,
long consumerCount) |
QueueDeleteBody(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait) |
QueuePurgeBody(int ticket,
AMQShortString queue,
boolean nowait) |
QueueUnbindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments) |
Modifier and Type | Method and Description |
---|---|
AMQShortString |
AMQConstant.getName()
Gets a short description of the status code.
|
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.
|
AMQShortString |
ConsumerTarget_0_8.getConsumerTag() |
AMQShortString |
IncomingMessage.getExchangeName() |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolOutputConverterImpl.confirmConsumerAutoClose(int channelId,
AMQShortString consumerTag) |
void |
ProtocolOutputConverter.confirmConsumerAutoClose(int channelId,
AMQShortString consumerTag) |
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) |
ConsumerTarget |
AMQChannel.getSubscription(AMQShortString tag) |
void |
AMQChannel.receiveAccessRequest(AMQShortString realm,
boolean exclusive,
boolean passive,
boolean active,
boolean write,
boolean read) |
void |
AMQChannel.receiveBasicCancel(AMQShortString consumerTag,
boolean nowait) |
void |
AMQChannel.receiveBasicConsume(AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
void |
AMQChannel.receiveBasicGet(AMQShortString queueName,
boolean noAck) |
void |
AMQChannel.receiveBasicPublish(AMQShortString exchangeName,
AMQShortString routingKey,
boolean mandatory,
boolean immediate) |
void |
AMQChannel.receiveChannelClose(int replyCode,
AMQShortString replyText,
int classId,
int methodId) |
void |
AMQPConnection_0_8.receiveConnectionClose(int replyCode,
AMQShortString replyText,
int classId,
int methodId) |
void |
AMQPConnection_0_8.receiveConnectionOpen(AMQShortString virtualHostName,
AMQShortString capabilities,
boolean insist) |
void |
AMQPConnection_0_8.receiveConnectionStartOk(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale) |
void |
AMQChannel.receiveExchangeBound(AMQShortString exchangeName,
AMQShortString routingKey,
AMQShortString queueName) |
void |
AMQChannel.receiveExchangeDeclare(AMQShortString exchangeName,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
void |
AMQChannel.receiveExchangeDelete(AMQShortString exchangeStr,
boolean ifUnused,
boolean nowait) |
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.receiveQueueDelete(AMQShortString queueName,
boolean ifUnused,
boolean ifEmpty,
boolean nowait) |
void |
AMQChannel.receiveQueuePurge(AMQShortString queueName,
boolean nowait) |
void |
AMQChannel.receiveQueueUnbind(AMQShortString queueName,
AMQShortString exchange,
AMQShortString bindingKey,
FieldTable arguments) |
boolean |
AMQChannel.unsubscribeConsumer(AMQShortString consumerTag)
Unsubscribe a consumer from a queue.
|
long |
ProtocolOutputConverterImpl.writeDeliver(ServerMessage m,
InstanceProperties props,
int channelId,
long deliveryTag,
AMQShortString consumerTag) |
long |
ProtocolOutputConverter.writeDeliver(ServerMessage msg,
InstanceProperties props,
int channelId,
long deliveryTag,
AMQShortString consumerTag) |
void |
ProtocolOutputConverterImpl.writeReturn(MessagePublishInfo messagePublishInfo,
ContentHeaderBody header,
MessageContentSource message,
int channelId,
int replyCode,
AMQShortString replyText) |
void |
ProtocolOutputConverter.writeReturn(MessagePublishInfo messagePublishInfo,
ContentHeaderBody header,
MessageContentSource msgContent,
int channelId,
int replyCode,
AMQShortString replyText) |
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 AMQShortString |
AMQShortStringEncoding.readShortString(com.sleepycat.bind.tuple.TupleInput tupleInput) |
Modifier and Type | Method and Description |
---|---|
static void |
AMQShortStringEncoding.writeShortString(AMQShortString shortString,
com.sleepycat.bind.tuple.TupleOutput tupleOutput) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.