| Modifier and Type | Method and Description |
|---|---|
AMQShortString |
MarkableDataInput.readAMQShortString() |
| Modifier and Type | Method and Description |
|---|---|
AMQShortString |
AMQPFilterTypes.getValue()
Gets the identifying string of the filter type.
|
| 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) |
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) |
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) |
abstract ExchangeBoundBody |
MethodRegistry.createExchangeBoundBody(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue) |
abstract ExchangeBoundOkBody |
MethodRegistry.createExchangeBoundOkBody(int replyCode,
AMQShortString replyText) |
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) |
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) |
abstract QueueDeclareOkBody |
MethodRegistry.createQueueDeclareOkBody(AMQShortString queue,
long messageCount,
long consumerCount) |
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) |
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) |
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) |
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) |
boolean |
AMQShortString.startsWith(AMQShortString otherString) |
static String |
AMQShortString.toString(AMQShortString amqShortString) |
protected void |
AMQMethodBodyImpl.writeAMQShortString(DataOutput buffer,
AMQShortString string) |
static void |
EncodingUtils.writeShortStringBytes(DataOutput buffer,
AMQShortString s) |
| Modifier and Type | Method and Description |
|---|---|
static AMQShortString |
AMQShortString.join(Collection<AMQShortString> terms,
AMQShortString delim) |
| Modifier and Type | Method and Description |
|---|---|
AMQShortString |
MessagePublishInfo.getExchange() |
AMQShortString |
MessagePublishInfoImpl.getExchange() |
AMQShortString |
MessagePublishInfo.getRoutingKey() |
AMQShortString |
MessagePublishInfoImpl.getRoutingKey() |
| Modifier and Type | Method and Description |
|---|---|
void |
MessagePublishInfo.setExchange(AMQShortString exchange) |
void |
MessagePublishInfoImpl.setExchange(AMQShortString exchange) |
void |
MessagePublishInfoImpl.setRoutingKey(AMQShortString routingKey) |
| Constructor and Description |
|---|
MessagePublishInfoImpl(AMQShortString exchange,
boolean immediate,
boolean mandatory,
AMQShortString routingKey) |
| Modifier and Type | Method and Description |
|---|---|
AMQShortString |
MessageTransferBodyImpl.getAppId() |
AMQShortString |
ConnectionOpenBodyImpl.getCapabilities() |
AMQShortString |
BasicGetEmptyBodyImpl.getClusterId() |
AMQShortString |
BasicDeliverBodyImpl.getConsumerTag() |
AMQShortString |
StreamCancelOkBodyImpl.getConsumerTag() |
AMQShortString |
StreamCancelBodyImpl.getConsumerTag() |
AMQShortString |
BasicConsumeOkBodyImpl.getConsumerTag() |
AMQShortString |
BasicCancelBodyImpl.getConsumerTag() |
AMQShortString |
FileConsumeBodyImpl.getConsumerTag() |
AMQShortString |
FileCancelOkBodyImpl.getConsumerTag() |
AMQShortString |
StreamConsumeBodyImpl.getConsumerTag() |
AMQShortString |
StreamDeliverBodyImpl.getConsumerTag() |
AMQShortString |
FileConsumeOkBodyImpl.getConsumerTag() |
AMQShortString |
FileDeliverBodyImpl.getConsumerTag() |
AMQShortString |
StreamConsumeOkBodyImpl.getConsumerTag() |
AMQShortString |
BasicConsumeBodyImpl.getConsumerTag() |
AMQShortString |
BasicCancelOkBodyImpl.getConsumerTag() |
AMQShortString |
FileCancelBodyImpl.getConsumerTag() |
AMQShortString |
MessageTransferBodyImpl.getContentEncoding() |
AMQShortString |
MessageTransferBodyImpl.getContentType() |
AMQShortString |
MessageTransferBodyImpl.getCorrelationId() |
AMQShortString |
MessageTransferBodyImpl.getDestination() |
AMQShortString |
MessageConsumeBodyImpl.getDestination() |
AMQShortString |
MessageCancelBodyImpl.getDestination() |
AMQShortString |
MessageGetBodyImpl.getDestination() |
AMQShortString |
DtxStartBodyImpl.getDtxIdentifier() |
AMQShortString |
BasicDeliverBodyImpl.getExchange() |
AMQShortString |
FileReturnBodyImpl.getExchange() |
AMQShortString |
BasicPublishBodyImpl.getExchange() |
AMQShortString |
ExchangeDeleteBodyImpl.getExchange() |
AMQShortString |
BasicReturnBodyImpl.getExchange() |
AMQShortString |
QueueBindBodyImpl.getExchange() |
AMQShortString |
MessageTransferBodyImpl.getExchange() |
AMQShortString |
FilePublishBodyImpl.getExchange() |
AMQShortString |
QueueUnbindBodyImpl.getExchange() |
AMQShortString |
ExchangeBoundBodyImpl.getExchange() |
AMQShortString |
StreamPublishBodyImpl.getExchange() |
AMQShortString |
BasicGetOkBodyImpl.getExchange() |
AMQShortString |
StreamDeliverBodyImpl.getExchange() |
AMQShortString |
ExchangeDeclareBodyImpl.getExchange() |
AMQShortString |
StreamReturnBodyImpl.getExchange() |
AMQShortString |
FileDeliverBodyImpl.getExchange() |
AMQShortString |
ConnectionRedirectBodyImpl.getHost() |
AMQShortString |
FileOpenBodyImpl.getIdentifier() |
AMQShortString |
FilePublishBodyImpl.getIdentifier() |
AMQShortString |
MessageCheckpointBodyImpl.getIdentifier() |
AMQShortString |
MessageResumeBodyImpl.getIdentifier() |
AMQShortString |
FileDeliverBodyImpl.getIdentifier() |
AMQShortString |
ConnectionRedirectBodyImpl.getKnownHosts() |
AMQShortString |
ConnectionOpenOkBodyImpl.getKnownHosts() |
AMQShortString |
ConnectionStartOkBodyImpl.getLocale() |
AMQShortString |
ConnectionStartOkBodyImpl.getMechanism() |
AMQShortString |
MessageTransferBodyImpl.getMessageId() |
AMQShortString |
ChannelOpenBodyImpl.getOutOfBand() |
AMQShortString |
QueueDeclareOkBodyImpl.getQueue() |
AMQShortString |
QueueBindBodyImpl.getQueue() |
AMQShortString |
QueueUnbindBodyImpl.getQueue() |
AMQShortString |
ExchangeBoundBodyImpl.getQueue() |
AMQShortString |
QueueDeleteBodyImpl.getQueue() |
AMQShortString |
FileConsumeBodyImpl.getQueue() |
AMQShortString |
MessageConsumeBodyImpl.getQueue() |
AMQShortString |
StreamConsumeBodyImpl.getQueue() |
AMQShortString |
StreamDeliverBodyImpl.getQueue() |
AMQShortString |
MessageGetBodyImpl.getQueue() |
AMQShortString |
BasicGetBodyImpl.getQueue() |
AMQShortString |
QueueDeclareBodyImpl.getQueue() |
AMQShortString |
QueuePurgeBodyImpl.getQueue() |
AMQShortString |
BasicConsumeBodyImpl.getQueue() |
AMQShortString |
AccessRequestBodyImpl.getRealm() |
AMQShortString |
FileReturnBodyImpl.getReplyText() |
AMQShortString |
BasicReturnBodyImpl.getReplyText() |
AMQShortString |
ExchangeBoundOkBodyImpl.getReplyText() |
AMQShortString |
StreamReturnBodyImpl.getReplyText() |
AMQShortString |
ConnectionCloseBodyImpl.getReplyText() |
AMQShortString |
ChannelCloseBodyImpl.getReplyText() |
AMQShortString |
MessageTransferBodyImpl.getReplyTo() |
AMQShortString |
BasicDeliverBodyImpl.getRoutingKey() |
AMQShortString |
FileReturnBodyImpl.getRoutingKey() |
AMQShortString |
BasicPublishBodyImpl.getRoutingKey() |
AMQShortString |
BasicReturnBodyImpl.getRoutingKey() |
AMQShortString |
QueueBindBodyImpl.getRoutingKey() |
AMQShortString |
MessageTransferBodyImpl.getRoutingKey() |
AMQShortString |
FilePublishBodyImpl.getRoutingKey() |
AMQShortString |
QueueUnbindBodyImpl.getRoutingKey() |
AMQShortString |
ExchangeBoundBodyImpl.getRoutingKey() |
AMQShortString |
StreamPublishBodyImpl.getRoutingKey() |
AMQShortString |
BasicGetOkBodyImpl.getRoutingKey() |
AMQShortString |
StreamReturnBodyImpl.getRoutingKey() |
AMQShortString |
FileDeliverBodyImpl.getRoutingKey() |
AMQShortString |
MessageRejectBodyImpl.getText() |
AMQShortString |
MessageTransferBodyImpl.getTransactionId() |
AMQShortString |
ExchangeDeclareBodyImpl.getType() |
AMQShortString |
MessageTransferBodyImpl.getUserId() |
AMQShortString |
ConnectionOpenBodyImpl.getVirtualHost() |
| Modifier and Type | Method and Description |
|---|---|
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) |
| Constructor and Description |
|---|
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) |
| Modifier and Type | Method and Description |
|---|---|
AMQShortString |
ConnectionOpenBodyImpl.getCapabilities() |
AMQShortString |
BasicGetEmptyBodyImpl.getClusterId() |
AMQShortString |
BasicDeliverBodyImpl.getConsumerTag() |
AMQShortString |
BasicConsumeOkBodyImpl.getConsumerTag() |
AMQShortString |
BasicCancelBodyImpl.getConsumerTag() |
AMQShortString |
BasicConsumeBodyImpl.getConsumerTag() |
AMQShortString |
BasicCancelOkBodyImpl.getConsumerTag() |
AMQShortString |
BasicDeliverBodyImpl.getExchange() |
AMQShortString |
BasicPublishBodyImpl.getExchange() |
AMQShortString |
ExchangeDeleteBodyImpl.getExchange() |
AMQShortString |
BasicReturnBodyImpl.getExchange() |
AMQShortString |
QueueBindBodyImpl.getExchange() |
AMQShortString |
QueueUnbindBodyImpl.getExchange() |
AMQShortString |
ExchangeBoundBodyImpl.getExchange() |
AMQShortString |
BasicGetOkBodyImpl.getExchange() |
AMQShortString |
ExchangeDeclareBodyImpl.getExchange() |
AMQShortString |
ConnectionOpenOkBodyImpl.getKnownHosts() |
AMQShortString |
ConnectionStartOkBodyImpl.getLocale() |
AMQShortString |
ConnectionStartOkBodyImpl.getMechanism() |
AMQShortString |
ChannelOpenBodyImpl.getOutOfBand() |
AMQShortString |
QueueDeclareOkBodyImpl.getQueue() |
AMQShortString |
QueueBindBodyImpl.getQueue() |
AMQShortString |
QueueUnbindBodyImpl.getQueue() |
AMQShortString |
ExchangeBoundBodyImpl.getQueue() |
AMQShortString |
QueueDeleteBodyImpl.getQueue() |
AMQShortString |
BasicGetBodyImpl.getQueue() |
AMQShortString |
QueueDeclareBodyImpl.getQueue() |
AMQShortString |
QueuePurgeBodyImpl.getQueue() |
AMQShortString |
BasicConsumeBodyImpl.getQueue() |
AMQShortString |
BasicReturnBodyImpl.getReplyText() |
AMQShortString |
ExchangeBoundOkBodyImpl.getReplyText() |
AMQShortString |
ConnectionCloseBodyImpl.getReplyText() |
AMQShortString |
ChannelCloseBodyImpl.getReplyText() |
AMQShortString |
BasicDeliverBodyImpl.getRoutingKey() |
AMQShortString |
BasicPublishBodyImpl.getRoutingKey() |
AMQShortString |
BasicReturnBodyImpl.getRoutingKey() |
AMQShortString |
QueueBindBodyImpl.getRoutingKey() |
AMQShortString |
QueueUnbindBodyImpl.getRoutingKey() |
AMQShortString |
ExchangeBoundBodyImpl.getRoutingKey() |
AMQShortString |
BasicGetOkBodyImpl.getRoutingKey() |
AMQShortString |
ExchangeDeclareBodyImpl.getType() |
AMQShortString |
ConnectionOpenBodyImpl.getVirtualHost() |
| Modifier and Type | Method and Description |
|---|---|
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) |
| Constructor and Description |
|---|
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) |
| Modifier and Type | Method and Description |
|---|---|
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) |
| Constructor and Description |
|---|
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) |
| Modifier and Type | Method and Description |
|---|---|
AMQShortString |
AMQConstant.getName()
Gets a short description of the status code.
|
| Modifier and Type | Method and Description |
|---|---|
AMQShortString[] |
BindingURL.getBindingKeys() |
AMQShortString[] |
AMQBindingURL.getBindingKeys() |
AMQShortString |
BindingURL.getDestinationName() |
AMQShortString |
AMQBindingURL.getDestinationName() |
AMQShortString |
BindingURL.getExchangeClass() |
AMQShortString |
AMQBindingURL.getExchangeClass() |
AMQShortString |
BindingURL.getExchangeName() |
AMQShortString |
AMQBindingURL.getExchangeName() |
AMQShortString |
BindingURL.getQueueName() |
AMQShortString |
AMQBindingURL.getQueueName() |
AMQShortString |
BindingURL.getRoutingKey() |
AMQShortString |
AMQBindingURL.getRoutingKey() |
| Modifier and Type | Method and Description |
|---|---|
void |
AMQBindingURL.setBindingKeys(AMQShortString[] keys) |
void |
AMQBindingURL.setQueueName(AMQShortString name) |
void |
AMQBindingURL.setRoutingKey(AMQShortString key) |
Copyright © 2006–2014 The Apache Software Foundation. All rights reserved.