|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of AMQShortString in org.apache.qpid.common |
---|
Methods in org.apache.qpid.common that return AMQShortString | |
---|---|
AMQShortString |
AMQPFilterTypes.getValue()
Gets the identifying string of the filter type. |
AMQShortString |
ClientProperties.toAMQShortString()
|
Uses of AMQShortString in org.apache.qpid.exchange |
---|
Fields in org.apache.qpid.exchange declared as AMQShortString | |
---|---|
static AMQShortString |
ExchangeDefaults.DEFAULT_EXCHANGE_NAME
The default direct exchange, which is a special internal exchange that cannot be explicitly bound to. |
static AMQShortString |
ExchangeDefaults.DIRECT_EXCHANGE_CLASS
Defines the identifying type name of direct exchanges. |
static AMQShortString |
ExchangeDefaults.DIRECT_EXCHANGE_NAME
The pre-defined direct exchange, the broker MUST provide this. |
static AMQShortString |
ExchangeDefaults.FANOUT_EXCHANGE_CLASS
Defines the identifying type name of fanout exchanges. |
static AMQShortString |
ExchangeDefaults.FANOUT_EXCHANGE_NAME
The pre-defined fanout exchange, the boker MUST provide this. |
static AMQShortString |
ExchangeDefaults.HEADERS_EXCHANGE_CLASS
Defines the identifying type name of headers exchanges. |
static AMQShortString |
ExchangeDefaults.HEADERS_EXCHANGE_NAME
The pre-defined headers exchange, the specification does not say this needs to be provided. |
static AMQShortString |
ExchangeDefaults.TOPIC_EXCHANGE_CLASS
Defines the identifying type name of topic exchanges. |
static AMQShortString |
ExchangeDefaults.TOPIC_EXCHANGE_NAME
The pre-defined topic exchange, the broker SHOULD provide this. |
static AMQShortString |
ExchangeDefaults.WILDCARD_ANY
|
Uses of AMQShortString in org.apache.qpid.framing |
---|
Fields in org.apache.qpid.framing declared as AMQShortString | |
---|---|
static AMQShortString |
AMQShortString.EMPTY_STRING
|
Methods in org.apache.qpid.framing that return types with arguments of type AMQShortString | |
---|---|
Iterator<Map.Entry<AMQShortString,AMQTypedValue>> |
FieldTable.iterator()
|
Set<AMQShortString> |
FieldTable.keySet()
|
Methods in org.apache.qpid.framing with parameters of type AMQShortString | |
---|---|
protected static void |
FieldTable.checkIdentiferFormat(AMQShortString propertyName)
|
int |
AMQShortString.compareTo(AMQShortString name)
|
boolean |
FieldTable.containsKey(AMQShortString key)
|
AccessRequestBody |
AMQMethodFactory.createAccessRequest(boolean active,
boolean exclusive,
boolean passive,
boolean read,
AMQShortString realm,
boolean write)
|
abstract BasicCancelBody |
MethodRegistry.createBasicCancelBody(AMQShortString consumerTag,
boolean nowait)
|
abstract BasicCancelOkBody |
MethodRegistry.createBasicCancelOkBody(AMQShortString consumerTag)
|
abstract BasicConsumeBody |
MethodRegistry.createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments)
|
abstract BasicConsumeOkBody |
MethodRegistry.createBasicConsumeOkBody(AMQShortString consumerTag)
|
abstract BasicDeliverBody |
MethodRegistry.createBasicDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey)
|
abstract BasicGetBody |
MethodRegistry.createBasicGetBody(int ticket,
AMQShortString queue,
boolean noAck)
|
abstract BasicGetEmptyBody |
MethodRegistry.createBasicGetEmptyBody(AMQShortString clusterId)
|
abstract BasicGetOkBody |
MethodRegistry.createBasicGetOkBody(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount)
|
abstract BasicPublishBody |
MethodRegistry.createBasicPublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
abstract BasicReturnBody |
MethodRegistry.createBasicReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
ChannelCloseBody |
AMQMethodFactory.createChannelClose(int replyCode,
AMQShortString replyText)
|
abstract ChannelCloseBody |
MethodRegistry.createChannelCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
abstract ChannelOpenBody |
MethodRegistry.createChannelOpenBody(AMQShortString outOfBand)
|
abstract ConnectionCloseBody |
MethodRegistry.createConnectionCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
abstract ConnectionOpenBody |
MethodRegistry.createConnectionOpenBody(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist)
|
abstract ConnectionOpenOkBody |
MethodRegistry.createConnectionOpenOkBody(AMQShortString knownHosts)
|
abstract ConnectionStartOkBody |
MethodRegistry.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale)
|
AMQMethodBody |
AMQMethodFactory.createConsumer(AMQShortString tag,
AMQShortString queueName,
FieldTable arguments,
boolean noAck,
boolean exclusive,
boolean noLocal,
int ticket)
|
AMQMethodBody |
AMQMethodFactory.createConsumerCancel(AMQShortString consumerTag)
|
ExchangeBoundBody |
AMQMethodFactory.createExchangeBound(AMQShortString exchangeName,
AMQShortString queueName,
AMQShortString routingKey)
|
abstract ExchangeBoundBody |
MethodRegistry.createExchangeBoundBody(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue)
|
abstract ExchangeBoundOkBody |
MethodRegistry.createExchangeBoundOkBody(int replyCode,
AMQShortString replyText)
|
ExchangeDeclareBody |
AMQMethodFactory.createExchangeDeclare(AMQShortString name,
AMQShortString type,
int ticket)
|
abstract ExchangeDeclareBody |
MethodRegistry.createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments)
|
abstract ExchangeDeleteBody |
MethodRegistry.createExchangeDeleteBody(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait)
|
QueueBindBody |
AMQMethodFactory.createQueueBind(AMQShortString queueName,
AMQShortString exchangeName,
AMQShortString routingKey,
FieldTable arguments,
int ticket)
|
abstract QueueBindBody |
MethodRegistry.createQueueBindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments)
|
QueueDeclareBody |
AMQMethodFactory.createQueueDeclare(AMQShortString name,
FieldTable arguments,
boolean autoDelete,
boolean durable,
boolean exclusive,
boolean passive,
int ticket)
|
abstract QueueDeclareBody |
MethodRegistry.createQueueDeclareBody(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments)
|
abstract QueueDeclareOkBody |
MethodRegistry.createQueueDeclareOkBody(AMQShortString queue,
long messageCount,
long consumerCount)
|
QueueDeleteBody |
AMQMethodFactory.createQueueDelete(AMQShortString queueName,
boolean ifEmpty,
boolean ifUnused,
int ticket)
|
abstract QueueDeleteBody |
MethodRegistry.createQueueDeleteBody(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait)
|
abstract QueuePurgeBody |
MethodRegistry.createQueuePurgeBody(int ticket,
AMQShortString queue,
boolean nowait)
|
static int |
EncodingUtils.encodedShortStringLength(AMQShortString s)
|
boolean |
AMQShortString.endsWith(AMQShortString otherString)
|
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)
|
static AMQShortString |
AMQShortString.join(Collection<AMQShortString> terms,
AMQShortString delim)
|
boolean |
FieldTable.propertyExists(AMQShortString propertyName)
|
Object |
FieldTable.put(AMQShortString key,
Object value)
|
Object |
FieldTable.remove(AMQShortString key)
|
AMQTypedValue |
FieldTable.removeKey(AMQShortString key)
|
void |
BasicContentHeaderProperties.setAppId(AMQShortString appId)
|
void |
CommonContentHeaderProperties.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 |
CommonContentHeaderProperties.setClusterId(AMQShortString clusterId)
|
void |
BasicContentHeaderProperties.setContentType(AMQShortString contentType)
|
void |
CommonContentHeaderProperties.setContentType(AMQShortString contentType)
|
void |
BasicContentHeaderProperties.setCorrelationId(AMQShortString correlationId)
|
void |
CommonContentHeaderProperties.setCorrelationId(AMQShortString correlationId)
|
Object |
FieldTable.setDecimal(AMQShortString string,
BigDecimal decimal)
|
Object |
FieldTable.setDouble(AMQShortString string,
Double v)
|
void |
BasicContentHeaderProperties.setEncoding(AMQShortString encoding)
|
void |
CommonContentHeaderProperties.setEncoding(AMQShortString encoding)
|
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,
Integer i)
|
Object |
FieldTable.setLong(AMQShortString string,
Long l)
|
void |
BasicContentHeaderProperties.setMessageId(AMQShortString messageId)
|
void |
CommonContentHeaderProperties.setMessageId(AMQShortString messageId)
|
Object |
FieldTable.setObject(AMQShortString string,
Object object)
|
void |
BasicContentHeaderProperties.setReplyTo(AMQShortString replyTo)
|
void |
CommonContentHeaderProperties.setReplyTo(AMQShortString replyTo)
|
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 |
CommonContentHeaderProperties.setType(AMQShortString type)
|
void |
BasicContentHeaderProperties.setUserId(AMQShortString userId)
|
void |
CommonContentHeaderProperties.setUserId(AMQShortString userId)
|
Object |
FieldTable.setVoid(AMQShortString string)
|
boolean |
AMQShortString.startsWith(AMQShortString otherString)
|
protected void |
AMQMethodBodyImpl.writeAMQShortString(org.apache.mina.common.ByteBuffer buffer,
AMQShortString string)
|
static void |
EncodingUtils.writeShortStringBytes(org.apache.mina.common.ByteBuffer buffer,
AMQShortString s)
|
Method parameters in org.apache.qpid.framing with type arguments of type AMQShortString | |
---|---|
static AMQShortString |
AMQShortString.join(Collection<AMQShortString> terms,
AMQShortString delim)
|
Uses of AMQShortString in org.apache.qpid.framing.abstraction |
---|
Methods in org.apache.qpid.framing.abstraction that return AMQShortString | |
---|---|
AMQShortString |
MessagePublishInfo.getExchange()
|
AMQShortString |
MessagePublishInfoImpl.getExchange()
|
AMQShortString |
MessagePublishInfo.getRoutingKey()
|
AMQShortString |
MessagePublishInfoImpl.getRoutingKey()
|
Methods in org.apache.qpid.framing.abstraction with parameters of type AMQShortString | |
---|---|
void |
MessagePublishInfo.setExchange(AMQShortString exchange)
|
void |
MessagePublishInfoImpl.setExchange(AMQShortString exchange)
|
void |
MessagePublishInfoImpl.setRoutingKey(AMQShortString routingKey)
|
Constructors in org.apache.qpid.framing.abstraction with parameters of type AMQShortString | |
---|---|
MessagePublishInfoImpl(AMQShortString exchange,
boolean immediate,
boolean mandatory,
AMQShortString routingKey)
|
Uses of AMQShortString in org.apache.qpid.framing.amqp_0_9 |
---|
Methods in org.apache.qpid.framing.amqp_0_9 with parameters of type AMQShortString | |
---|---|
AccessRequestBody |
MethodRegistry_0_9.createAccessRequestBody(AMQShortString realm,
boolean exclusive,
boolean passive,
boolean active,
boolean write,
boolean read)
|
BasicCancelBody |
MethodRegistry_0_9.createBasicCancelBody(AMQShortString consumerTag,
boolean nowait)
|
BasicCancelOkBody |
MethodRegistry_0_9.createBasicCancelOkBody(AMQShortString consumerTag)
|
BasicConsumeBody |
MethodRegistry_0_9.createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments)
|
BasicConsumeOkBody |
MethodRegistry_0_9.createBasicConsumeOkBody(AMQShortString consumerTag)
|
BasicDeliverBody |
MethodRegistry_0_9.createBasicDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey)
|
BasicGetBody |
MethodRegistry_0_9.createBasicGetBody(int ticket,
AMQShortString queue,
boolean noAck)
|
BasicGetEmptyBody |
MethodRegistry_0_9.createBasicGetEmptyBody(AMQShortString clusterId)
|
BasicGetOkBody |
MethodRegistry_0_9.createBasicGetOkBody(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount)
|
BasicPublishBody |
MethodRegistry_0_9.createBasicPublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
BasicReturnBody |
MethodRegistry_0_9.createBasicReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
ChannelCloseBody |
MethodRegistry_0_9.createChannelCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
ChannelOpenBody |
MethodRegistry_0_9.createChannelOpenBody(AMQShortString outOfBand)
|
ConnectionCloseBody |
MethodRegistry_0_9.createConnectionCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
ConnectionOpenBody |
MethodRegistry_0_9.createConnectionOpenBody(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist)
|
ConnectionOpenOkBody |
MethodRegistry_0_9.createConnectionOpenOkBody(AMQShortString knownHosts)
|
ConnectionRedirectBody |
MethodRegistry_0_9.createConnectionRedirectBody(AMQShortString host,
AMQShortString knownHosts)
|
ConnectionStartOkBody |
MethodRegistry_0_9.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale)
|
DtxStartBody |
MethodRegistry_0_9.createDtxStartBody(AMQShortString dtxIdentifier)
|
ExchangeBoundBody |
MethodRegistry_0_9.createExchangeBoundBody(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue)
|
ExchangeBoundOkBody |
MethodRegistry_0_9.createExchangeBoundOkBody(int replyCode,
AMQShortString replyText)
|
ExchangeDeclareBody |
MethodRegistry_0_9.createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments)
|
ExchangeDeleteBody |
MethodRegistry_0_9.createExchangeDeleteBody(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait)
|
FileCancelBody |
MethodRegistry_0_9.createFileCancelBody(AMQShortString consumerTag,
boolean nowait)
|
FileCancelOkBody |
MethodRegistry_0_9.createFileCancelOkBody(AMQShortString consumerTag)
|
FileConsumeBody |
MethodRegistry_0_9.createFileConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable filter)
|
FileConsumeOkBody |
MethodRegistry_0_9.createFileConsumeOkBody(AMQShortString consumerTag)
|
FileDeliverBody |
MethodRegistry_0_9.createFileDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
AMQShortString identifier)
|
FileOpenBody |
MethodRegistry_0_9.createFileOpenBody(AMQShortString identifier,
long contentSize)
|
FilePublishBody |
MethodRegistry_0_9.createFilePublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate,
AMQShortString identifier)
|
FileReturnBody |
MethodRegistry_0_9.createFileReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
MessageCancelBody |
MethodRegistry_0_9.createMessageCancelBody(AMQShortString destination)
|
MessageCheckpointBody |
MethodRegistry_0_9.createMessageCheckpointBody(byte[] reference,
AMQShortString identifier)
|
MessageConsumeBody |
MethodRegistry_0_9.createMessageConsumeBody(int ticket,
AMQShortString queue,
AMQShortString destination,
boolean noLocal,
boolean noAck,
boolean exclusive,
FieldTable filter)
|
MessageGetBody |
MethodRegistry_0_9.createMessageGetBody(int ticket,
AMQShortString queue,
AMQShortString destination,
boolean noAck)
|
MessageRejectBody |
MethodRegistry_0_9.createMessageRejectBody(int code,
AMQShortString text)
|
MessageResumeBody |
MethodRegistry_0_9.createMessageResumeBody(byte[] reference,
AMQShortString identifier)
|
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)
|
QueueDeclareOkBody |
MethodRegistry_0_9.createQueueDeclareOkBody(AMQShortString queue,
long messageCount,
long consumerCount)
|
QueueDeleteBody |
MethodRegistry_0_9.createQueueDeleteBody(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait)
|
QueuePurgeBody |
MethodRegistry_0_9.createQueuePurgeBody(int ticket,
AMQShortString queue,
boolean nowait)
|
QueueUnbindBody |
MethodRegistry_0_9.createQueueUnbindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments)
|
StreamCancelBody |
MethodRegistry_0_9.createStreamCancelBody(AMQShortString consumerTag,
boolean nowait)
|
StreamCancelOkBody |
MethodRegistry_0_9.createStreamCancelOkBody(AMQShortString consumerTag)
|
StreamConsumeBody |
MethodRegistry_0_9.createStreamConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean exclusive,
boolean nowait,
FieldTable filter)
|
StreamConsumeOkBody |
MethodRegistry_0_9.createStreamConsumeOkBody(AMQShortString consumerTag)
|
StreamDeliverBody |
MethodRegistry_0_9.createStreamDeliverBody(AMQShortString consumerTag,
long deliveryTag,
AMQShortString exchange,
AMQShortString queue)
|
StreamPublishBody |
MethodRegistry_0_9.createStreamPublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
StreamReturnBody |
MethodRegistry_0_9.createStreamReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
Constructors in org.apache.qpid.framing.amqp_0_9 with parameters of type AMQShortString | |
---|---|
AccessRequestBodyImpl(AMQShortString realm,
boolean exclusive,
boolean passive,
boolean active,
boolean write,
boolean read)
|
|
BasicCancelBodyImpl(AMQShortString consumerTag,
boolean nowait)
|
|
BasicCancelOkBodyImpl(AMQShortString consumerTag)
|
|
BasicConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments)
|
|
BasicConsumeOkBodyImpl(AMQShortString consumerTag)
|
|
BasicDeliverBodyImpl(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey)
|
|
BasicGetBodyImpl(int ticket,
AMQShortString queue,
boolean noAck)
|
|
BasicGetEmptyBodyImpl(AMQShortString clusterId)
|
|
BasicGetOkBodyImpl(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount)
|
|
BasicPublishBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
|
BasicReturnBodyImpl(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
|
ChannelCloseBodyImpl(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
|
ChannelOpenBodyImpl(AMQShortString outOfBand)
|
|
ConnectionCloseBodyImpl(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
|
ConnectionOpenBodyImpl(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist)
|
|
ConnectionOpenOkBodyImpl(AMQShortString knownHosts)
|
|
ConnectionRedirectBodyImpl(AMQShortString host,
AMQShortString knownHosts)
|
|
ConnectionStartOkBodyImpl(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale)
|
|
DtxStartBodyImpl(AMQShortString dtxIdentifier)
|
|
ExchangeBoundBodyImpl(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue)
|
|
ExchangeBoundOkBodyImpl(int replyCode,
AMQShortString replyText)
|
|
ExchangeDeclareBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments)
|
|
ExchangeDeleteBodyImpl(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait)
|
|
FileCancelBodyImpl(AMQShortString consumerTag,
boolean nowait)
|
|
FileCancelOkBodyImpl(AMQShortString consumerTag)
|
|
FileConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable filter)
|
|
FileConsumeOkBodyImpl(AMQShortString consumerTag)
|
|
FileDeliverBodyImpl(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
AMQShortString identifier)
|
|
FileOpenBodyImpl(AMQShortString identifier,
long contentSize)
|
|
FilePublishBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate,
AMQShortString identifier)
|
|
FileReturnBodyImpl(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
|
MessageCancelBodyImpl(AMQShortString destination)
|
|
MessageCheckpointBodyImpl(byte[] reference,
AMQShortString identifier)
|
|
MessageConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString destination,
boolean noLocal,
boolean noAck,
boolean exclusive,
FieldTable filter)
|
|
MessageGetBodyImpl(int ticket,
AMQShortString queue,
AMQShortString destination,
boolean noAck)
|
|
MessageRejectBodyImpl(int code,
AMQShortString text)
|
|
MessageResumeBodyImpl(byte[] reference,
AMQShortString identifier)
|
|
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)
|
|
QueueDeclareOkBodyImpl(AMQShortString queue,
long messageCount,
long consumerCount)
|
|
QueueDeleteBodyImpl(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait)
|
|
QueuePurgeBodyImpl(int ticket,
AMQShortString queue,
boolean nowait)
|
|
QueueUnbindBodyImpl(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments)
|
|
StreamCancelBodyImpl(AMQShortString consumerTag,
boolean nowait)
|
|
StreamCancelOkBodyImpl(AMQShortString consumerTag)
|
|
StreamConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean exclusive,
boolean nowait,
FieldTable filter)
|
|
StreamConsumeOkBodyImpl(AMQShortString consumerTag)
|
|
StreamDeliverBodyImpl(AMQShortString consumerTag,
long deliveryTag,
AMQShortString exchange,
AMQShortString queue)
|
|
StreamPublishBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
|
StreamReturnBodyImpl(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
Uses of AMQShortString in org.apache.qpid.framing.amqp_0_91 |
---|
Methods in org.apache.qpid.framing.amqp_0_91 with parameters of type AMQShortString | |
---|---|
BasicCancelBody |
MethodRegistry_0_91.createBasicCancelBody(AMQShortString consumerTag,
boolean nowait)
|
BasicCancelOkBody |
MethodRegistry_0_91.createBasicCancelOkBody(AMQShortString consumerTag)
|
BasicConsumeBody |
MethodRegistry_0_91.createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments)
|
BasicConsumeOkBody |
MethodRegistry_0_91.createBasicConsumeOkBody(AMQShortString consumerTag)
|
BasicDeliverBody |
MethodRegistry_0_91.createBasicDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey)
|
BasicGetBody |
MethodRegistry_0_91.createBasicGetBody(int ticket,
AMQShortString queue,
boolean noAck)
|
BasicGetEmptyBody |
MethodRegistry_0_91.createBasicGetEmptyBody(AMQShortString clusterId)
|
BasicGetOkBody |
MethodRegistry_0_91.createBasicGetOkBody(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount)
|
BasicPublishBody |
MethodRegistry_0_91.createBasicPublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
BasicReturnBody |
MethodRegistry_0_91.createBasicReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
ChannelCloseBody |
MethodRegistry_0_91.createChannelCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
ChannelOpenBody |
MethodRegistry_0_91.createChannelOpenBody(AMQShortString outOfBand)
|
ConnectionCloseBody |
MethodRegistry_0_91.createConnectionCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
ConnectionOpenBody |
MethodRegistry_0_91.createConnectionOpenBody(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist)
|
ConnectionOpenOkBody |
MethodRegistry_0_91.createConnectionOpenOkBody(AMQShortString knownHosts)
|
ConnectionStartOkBody |
MethodRegistry_0_91.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale)
|
ExchangeBoundBody |
MethodRegistry_0_91.createExchangeBoundBody(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue)
|
ExchangeBoundOkBody |
MethodRegistry_0_91.createExchangeBoundOkBody(int replyCode,
AMQShortString replyText)
|
ExchangeDeclareBody |
MethodRegistry_0_91.createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments)
|
ExchangeDeleteBody |
MethodRegistry_0_91.createExchangeDeleteBody(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait)
|
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)
|
QueueDeclareOkBody |
MethodRegistry_0_91.createQueueDeclareOkBody(AMQShortString queue,
long messageCount,
long consumerCount)
|
QueueDeleteBody |
MethodRegistry_0_91.createQueueDeleteBody(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait)
|
QueuePurgeBody |
MethodRegistry_0_91.createQueuePurgeBody(int ticket,
AMQShortString queue,
boolean nowait)
|
QueueUnbindBody |
MethodRegistry_0_91.createQueueUnbindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments)
|
Constructors in org.apache.qpid.framing.amqp_0_91 with parameters of type AMQShortString | |
---|---|
BasicCancelBodyImpl(AMQShortString consumerTag,
boolean nowait)
|
|
BasicCancelOkBodyImpl(AMQShortString consumerTag)
|
|
BasicConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments)
|
|
BasicConsumeOkBodyImpl(AMQShortString consumerTag)
|
|
BasicDeliverBodyImpl(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey)
|
|
BasicGetBodyImpl(int ticket,
AMQShortString queue,
boolean noAck)
|
|
BasicGetEmptyBodyImpl(AMQShortString clusterId)
|
|
BasicGetOkBodyImpl(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount)
|
|
BasicPublishBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
|
BasicReturnBodyImpl(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
|
ChannelCloseBodyImpl(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
|
ChannelOpenBodyImpl(AMQShortString outOfBand)
|
|
ConnectionCloseBodyImpl(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
|
ConnectionOpenBodyImpl(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist)
|
|
ConnectionOpenOkBodyImpl(AMQShortString knownHosts)
|
|
ConnectionStartOkBodyImpl(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale)
|
|
ExchangeBoundBodyImpl(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue)
|
|
ExchangeBoundOkBodyImpl(int replyCode,
AMQShortString replyText)
|
|
ExchangeDeclareBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments)
|
|
ExchangeDeleteBodyImpl(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait)
|
|
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)
|
|
QueueDeclareOkBodyImpl(AMQShortString queue,
long messageCount,
long consumerCount)
|
|
QueueDeleteBodyImpl(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait)
|
|
QueuePurgeBodyImpl(int ticket,
AMQShortString queue,
boolean nowait)
|
|
QueueUnbindBodyImpl(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
FieldTable arguments)
|
Uses of AMQShortString in org.apache.qpid.framing.amqp_8_0 |
---|
Methods in org.apache.qpid.framing.amqp_8_0 with parameters of type AMQShortString | |
---|---|
AccessRequestBody |
MethodRegistry_8_0.createAccessRequestBody(AMQShortString realm,
boolean exclusive,
boolean passive,
boolean active,
boolean write,
boolean read)
|
BasicCancelBody |
MethodRegistry_8_0.createBasicCancelBody(AMQShortString consumerTag,
boolean nowait)
|
BasicCancelOkBody |
MethodRegistry_8_0.createBasicCancelOkBody(AMQShortString consumerTag)
|
BasicConsumeBody |
MethodRegistry_8_0.createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments)
|
BasicConsumeOkBody |
MethodRegistry_8_0.createBasicConsumeOkBody(AMQShortString consumerTag)
|
BasicDeliverBody |
MethodRegistry_8_0.createBasicDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey)
|
BasicGetBody |
MethodRegistry_8_0.createBasicGetBody(int ticket,
AMQShortString queue,
boolean noAck)
|
BasicGetEmptyBody |
MethodRegistry_8_0.createBasicGetEmptyBody(AMQShortString clusterId)
|
BasicGetOkBody |
MethodRegistry_8_0.createBasicGetOkBody(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount)
|
BasicPublishBody |
MethodRegistry_8_0.createBasicPublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
BasicReturnBody |
MethodRegistry_8_0.createBasicReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
ChannelAlertBody |
MethodRegistry_8_0.createChannelAlertBody(int replyCode,
AMQShortString replyText,
FieldTable details)
|
ChannelCloseBody |
MethodRegistry_8_0.createChannelCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
ChannelOpenBody |
MethodRegistry_8_0.createChannelOpenBody(AMQShortString outOfBand)
|
ConnectionCloseBody |
MethodRegistry_8_0.createConnectionCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
ConnectionOpenBody |
MethodRegistry_8_0.createConnectionOpenBody(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist)
|
ConnectionOpenOkBody |
MethodRegistry_8_0.createConnectionOpenOkBody(AMQShortString knownHosts)
|
ConnectionRedirectBody |
MethodRegistry_8_0.createConnectionRedirectBody(AMQShortString host,
AMQShortString knownHosts)
|
ConnectionStartOkBody |
MethodRegistry_8_0.createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale)
|
DtxStartBody |
MethodRegistry_8_0.createDtxStartBody(AMQShortString dtxIdentifier)
|
ExchangeBoundBody |
MethodRegistry_8_0.createExchangeBoundBody(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue)
|
ExchangeBoundOkBody |
MethodRegistry_8_0.createExchangeBoundOkBody(int replyCode,
AMQShortString replyText)
|
ExchangeDeclareBody |
MethodRegistry_8_0.createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments)
|
ExchangeDeleteBody |
MethodRegistry_8_0.createExchangeDeleteBody(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait)
|
FileCancelBody |
MethodRegistry_8_0.createFileCancelBody(AMQShortString consumerTag,
boolean nowait)
|
FileCancelOkBody |
MethodRegistry_8_0.createFileCancelOkBody(AMQShortString consumerTag)
|
FileConsumeBody |
MethodRegistry_8_0.createFileConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait)
|
FileConsumeOkBody |
MethodRegistry_8_0.createFileConsumeOkBody(AMQShortString consumerTag)
|
FileDeliverBody |
MethodRegistry_8_0.createFileDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
AMQShortString identifier)
|
FileOpenBody |
MethodRegistry_8_0.createFileOpenBody(AMQShortString identifier,
long contentSize)
|
FilePublishBody |
MethodRegistry_8_0.createFilePublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate,
AMQShortString identifier)
|
FileReturnBody |
MethodRegistry_8_0.createFileReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
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)
|
QueueDeclareOkBody |
MethodRegistry_8_0.createQueueDeclareOkBody(AMQShortString queue,
long messageCount,
long consumerCount)
|
QueueDeleteBody |
MethodRegistry_8_0.createQueueDeleteBody(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait)
|
QueuePurgeBody |
MethodRegistry_8_0.createQueuePurgeBody(int ticket,
AMQShortString queue,
boolean nowait)
|
StreamCancelBody |
MethodRegistry_8_0.createStreamCancelBody(AMQShortString consumerTag,
boolean nowait)
|
StreamCancelOkBody |
MethodRegistry_8_0.createStreamCancelOkBody(AMQShortString consumerTag)
|
StreamConsumeBody |
MethodRegistry_8_0.createStreamConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean exclusive,
boolean nowait)
|
StreamConsumeOkBody |
MethodRegistry_8_0.createStreamConsumeOkBody(AMQShortString consumerTag)
|
StreamDeliverBody |
MethodRegistry_8_0.createStreamDeliverBody(AMQShortString consumerTag,
long deliveryTag,
AMQShortString exchange,
AMQShortString queue)
|
StreamPublishBody |
MethodRegistry_8_0.createStreamPublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
StreamReturnBody |
MethodRegistry_8_0.createStreamReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
TestStringBody |
MethodRegistry_8_0.createTestStringBody(AMQShortString string1,
byte[] string2,
short operation)
|
Constructors in org.apache.qpid.framing.amqp_8_0 with parameters of type AMQShortString | |
---|---|
AccessRequestBodyImpl(AMQShortString realm,
boolean exclusive,
boolean passive,
boolean active,
boolean write,
boolean read)
|
|
BasicCancelBodyImpl(AMQShortString consumerTag,
boolean nowait)
|
|
BasicCancelOkBodyImpl(AMQShortString consumerTag)
|
|
BasicConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments)
|
|
BasicConsumeOkBodyImpl(AMQShortString consumerTag)
|
|
BasicDeliverBodyImpl(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey)
|
|
BasicGetBodyImpl(int ticket,
AMQShortString queue,
boolean noAck)
|
|
BasicGetEmptyBodyImpl(AMQShortString clusterId)
|
|
BasicGetOkBodyImpl(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount)
|
|
BasicPublishBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
|
BasicReturnBodyImpl(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
|
ChannelAlertBodyImpl(int replyCode,
AMQShortString replyText,
FieldTable details)
|
|
ChannelCloseBodyImpl(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
|
ChannelOpenBodyImpl(AMQShortString outOfBand)
|
|
ConnectionCloseBodyImpl(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
|
ConnectionOpenBodyImpl(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist)
|
|
ConnectionOpenOkBodyImpl(AMQShortString knownHosts)
|
|
ConnectionRedirectBodyImpl(AMQShortString host,
AMQShortString knownHosts)
|
|
ConnectionStartOkBodyImpl(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale)
|
|
DtxStartBodyImpl(AMQShortString dtxIdentifier)
|
|
ExchangeBoundBodyImpl(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue)
|
|
ExchangeBoundOkBodyImpl(int replyCode,
AMQShortString replyText)
|
|
ExchangeDeclareBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments)
|
|
ExchangeDeleteBodyImpl(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait)
|
|
FileCancelBodyImpl(AMQShortString consumerTag,
boolean nowait)
|
|
FileCancelOkBodyImpl(AMQShortString consumerTag)
|
|
FileConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait)
|
|
FileConsumeOkBodyImpl(AMQShortString consumerTag)
|
|
FileDeliverBodyImpl(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
AMQShortString identifier)
|
|
FileOpenBodyImpl(AMQShortString identifier,
long contentSize)
|
|
FilePublishBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate,
AMQShortString identifier)
|
|
FileReturnBodyImpl(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
|
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)
|
|
QueueDeclareOkBodyImpl(AMQShortString queue,
long messageCount,
long consumerCount)
|
|
QueueDeleteBodyImpl(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait)
|
|
QueuePurgeBodyImpl(int ticket,
AMQShortString queue,
boolean nowait)
|
|
StreamCancelBodyImpl(AMQShortString consumerTag,
boolean nowait)
|
|
StreamCancelOkBodyImpl(AMQShortString consumerTag)
|
|
StreamConsumeBodyImpl(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean exclusive,
boolean nowait)
|
|
StreamConsumeOkBodyImpl(AMQShortString consumerTag)
|
|
StreamDeliverBodyImpl(AMQShortString consumerTag,
long deliveryTag,
AMQShortString exchange,
AMQShortString queue)
|
|
StreamPublishBodyImpl(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
|
StreamReturnBodyImpl(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
|
TestStringBodyImpl(AMQShortString string1,
byte[] string2,
short operation)
|
Uses of AMQShortString in org.apache.qpid.protocol |
---|
Methods in org.apache.qpid.protocol that return AMQShortString | |
---|---|
AMQShortString |
AMQConstant.getName()
Gets a short description of the status code. |
Uses of AMQShortString in org.apache.qpid.url |
---|
Fields in org.apache.qpid.url declared as AMQShortString | |
---|---|
(package private) AMQShortString[] |
AMQBindingURL._bindingKeys
|
(package private) AMQShortString |
AMQBindingURL._destinationName
|
(package private) AMQShortString |
AMQBindingURL._exchangeClass
|
(package private) AMQShortString |
AMQBindingURL._exchangeName
|
(package private) AMQShortString |
AMQBindingURL._queueName
|
Methods in org.apache.qpid.url that return AMQShortString | |
---|---|
AMQShortString[] |
AMQBindingURL.getBindingKeys()
|
AMQShortString[] |
BindingURL.getBindingKeys()
|
AMQShortString |
AMQBindingURL.getDestinationName()
|
AMQShortString |
BindingURL.getDestinationName()
|
AMQShortString |
AMQBindingURL.getExchangeClass()
|
AMQShortString |
BindingURL.getExchangeClass()
|
AMQShortString |
AMQBindingURL.getExchangeName()
|
AMQShortString |
BindingURL.getExchangeName()
|
AMQShortString |
AMQBindingURL.getQueueName()
|
AMQShortString |
BindingURL.getQueueName()
|
AMQShortString |
AMQBindingURL.getRoutingKey()
|
AMQShortString |
BindingURL.getRoutingKey()
|
Methods in org.apache.qpid.url with parameters of type AMQShortString | |
---|---|
void |
AMQBindingURL.setBindingKeys(AMQShortString[] keys)
|
void |
AMQBindingURL.setQueueName(AMQShortString name)
|
void |
AMQBindingURL.setRoutingKey(AMQShortString key)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |