Uses of Class
org.apache.qpid.server.protocol.v0_8.AMQShortString

Packages that use AMQShortString

Package	Description
org.apache.qpid.server.protocol.v0_8
org.apache.qpid.server.protocol.v0_8.transport

Uses of AMQShortString in org.apache.qpid.server.protocol.v0_8

Fields in org.apache.qpid.server.protocol.v0_8 declared as AMQShortString

Modifier and Type	Field and Description
static AMQShortString	AMQShortString.EMPTY_STRING

Methods in org.apache.qpid.server.protocol.v0_8 that return AMQShortString

Modifier and Type	Method and Description
static AMQShortString	AMQShortString.createAMQShortString(byte[] data)
static AMQShortString	AMQShortString.createAMQShortString(String string)
AMQShortString	ConsumerTarget_0_8.getConsumerTag()
AMQShortString	IncomingMessage.getExchangeName()
static AMQShortString	AMQShortString.readAMQShortString(QpidByteBuffer buffer)
static AMQShortString	AMQShortString.validValueOf(Object obj)
static AMQShortString	AMQShortString.valueOf(Object obj)
static AMQShortString	AMQShortString.valueOf(String obj)

Methods in org.apache.qpid.server.protocol.v0_8 with parameters of type AMQShortString

Modifier and Type	Method and Description
int	AMQShortString.compareTo(AMQShortString name)
void	ProtocolOutputConverterImpl.confirmConsumerAutoClose(int channelId, AMQShortString consumerTag)
void	ProtocolOutputConverter.confirmConsumerAutoClose(int channelId, AMQShortString consumerTag)
static ConsumerTarget_0_8	ConsumerTarget_0_8.createAckTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager_0_8 creditManager, boolean multiQueue)
static ConsumerTarget_0_8	ConsumerTarget_0_8.createBrowserTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager_0_8 creditManager, boolean multiQueue)
static ConsumerTarget_0_8	ConsumerTarget_0_8.createGetAckTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager_0_8 creditManager, ClientDeliveryMethod deliveryMethod)
static ConsumerTarget_0_8	ConsumerTarget_0_8.createGetNoAckTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager_0_8 creditManager, ClientDeliveryMethod deliveryMethod)
static ConsumerTarget_0_8	ConsumerTarget_0_8.createNoAckTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager_0_8 creditManager, boolean multiQueue)
static int	EncodingUtils.encodedShortStringLength(AMQShortString s)
boolean	AMQShortString.equals(AMQShortString otherString)
void	AMQChannel.receiveAccessRequest(AMQShortString realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read)
void	AMQChannel.receiveBasicCancel(AMQShortString consumerTag, boolean nowait)
void	AMQChannel.receiveBasicConsume(AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, FieldTable arguments)
void	AMQChannel.receiveBasicGet(AMQShortString queueName, boolean noAck)
void	AMQChannel.receiveBasicPublish(AMQShortString exchangeName, AMQShortString routingKey, boolean mandatory, boolean immediate)
void	AMQChannel.receiveChannelClose(int replyCode, AMQShortString replyText, int classId, int methodId)
void	AMQPConnection_0_8Impl.receiveConnectionClose(int replyCode, AMQShortString replyText, int classId, int methodId)
void	AMQPConnection_0_8Impl.receiveConnectionOpen(AMQShortString virtualHostName, AMQShortString capabilities, boolean insist)
void	AMQPConnection_0_8Impl.receiveConnectionStartOk(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
void	AMQChannel.receiveExchangeBound(AMQShortString exchangeName, AMQShortString routingKey, AMQShortString queueName)
void	AMQChannel.receiveExchangeDeclare(AMQShortString exchangeName, AMQShortString type, boolean passive, boolean durable, boolean autoDelete, boolean internal, boolean nowait, FieldTable arguments)
void	AMQChannel.receiveExchangeDelete(AMQShortString exchangeStr, boolean ifUnused, boolean nowait)
void	AMQChannel.receiveQueueBind(AMQShortString queueName, AMQShortString exchange, AMQShortString bindingKey, boolean nowait, FieldTable argumentsTable)
void	AMQChannel.receiveQueueDeclare(AMQShortString queueStr, boolean passive, boolean durable, boolean exclusive, boolean autoDelete, boolean nowait, FieldTable arguments)
void	AMQChannel.receiveQueueDelete(AMQShortString queueName, boolean ifUnused, boolean ifEmpty, boolean nowait)
void	AMQChannel.receiveQueuePurge(AMQShortString queueName, boolean nowait)
void	AMQChannel.receiveQueueUnbind(AMQShortString queueName, AMQShortString exchange, AMQShortString bindingKey, FieldTable arguments)
static String	AMQShortString.toString(AMQShortString amqShortString)
long	ProtocolOutputConverterImpl.writeDeliver(AMQMessage msg, InstanceProperties props, int channelId, long deliveryTag, AMQShortString consumerTag)
long	ProtocolOutputConverter.writeDeliver(AMQMessage msg, InstanceProperties props, int channelId, long deliveryTag, AMQShortString consumerTag)
void	ProtocolOutputConverterImpl.writeReturn(MessagePublishInfo messagePublishInfo, ContentHeaderBody header, MessageContentSource message, int channelId, int replyCode, AMQShortString replyText)
void	ProtocolOutputConverter.writeReturn(MessagePublishInfo messagePublishInfo, ContentHeaderBody header, MessageContentSource msgContent, int channelId, int replyCode, AMQShortString replyText)
static void	EncodingUtils.writeShortStringBytes(QpidByteBuffer buffer, AMQShortString s)

Constructors in org.apache.qpid.server.protocol.v0_8 with parameters of type AMQShortString

Constructor and Description
ConsumerTarget_0_8(AMQChannel channel, AMQShortString consumerTag, FieldTable arguments, FlowCreditManager_0_8 creditManager, ClientDeliveryMethod deliveryMethod, boolean multiQueue)
GetNoAckConsumer(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager_0_8 creditManager, ClientDeliveryMethod deliveryMethod)
NoAckConsumer(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager_0_8 creditManager, ClientDeliveryMethod deliveryMethod, boolean multiQueue)

Uses of AMQShortString in org.apache.qpid.server.protocol.v0_8.transport

Methods in org.apache.qpid.server.protocol.v0_8.transport that return AMQShortString

Modifier and Type	Method and Description
AMQShortString	BasicContentHeaderProperties.getAppId()
AMQShortString	ConnectionOpenBody.getCapabilities()
AMQShortString	BasicGetEmptyBody.getClusterId()
AMQShortString	BasicContentHeaderProperties.getClusterId()
AMQShortString	BasicDeliverBody.getConsumerTag()
AMQShortString	BasicConsumeOkBody.getConsumerTag()
AMQShortString	BasicConsumeBody.getConsumerTag()
AMQShortString	BasicCancelOkBody.getConsumerTag()
AMQShortString	BasicCancelBody.getConsumerTag()
AMQShortString	BasicContentHeaderProperties.getContentType()
AMQShortString	BasicContentHeaderProperties.getCorrelationId()
AMQShortString	BasicContentHeaderProperties.getEncoding()
AMQShortString	QueueUnbindBody.getExchange()
AMQShortString	QueueBindBody.getExchange()
AMQShortString	MessagePublishInfo.getExchange()
AMQShortString	ExchangeDeleteBody.getExchange()
AMQShortString	ExchangeDeclareBody.getExchange()
AMQShortString	ExchangeBoundBody.getExchange()
AMQShortString	BasicReturnBody.getExchange()
AMQShortString	BasicPublishBody.getExchange()
AMQShortString	BasicGetOkBody.getExchange()
AMQShortString	BasicDeliverBody.getExchange()
AMQShortString	ConnectionRedirectBody.getHost()
AMQShortString	ConnectionRedirectBody.getKnownHosts()
AMQShortString	ConnectionOpenOkBody.getKnownHosts()
AMQShortString	ConnectionStartOkBody.getLocale()
AMQShortString	ConnectionStartOkBody.getMechanism()
AMQShortString	BasicContentHeaderProperties.getMessageId()
AMQShortString	QueueUnbindBody.getQueue()
AMQShortString	QueuePurgeBody.getQueue()
AMQShortString	QueueDeleteBody.getQueue()
AMQShortString	QueueDeclareOkBody.getQueue()
AMQShortString	QueueDeclareBody.getQueue()
AMQShortString	QueueBindBody.getQueue()
AMQShortString	ExchangeBoundBody.getQueue()
AMQShortString	BasicGetBody.getQueue()
AMQShortString	BasicConsumeBody.getQueue()
AMQShortString	AccessRequestBody.getRealm()
AMQShortString	ExchangeBoundOkBody.getReplyText()
AMQShortString	ConnectionCloseBody.getReplyText()
AMQShortString	ChannelCloseBody.getReplyText()
AMQShortString	ChannelAlertBody.getReplyText()
AMQShortString	BasicReturnBody.getReplyText()
AMQShortString	BasicContentHeaderProperties.getReplyTo()
AMQShortString	QueueUnbindBody.getRoutingKey()
AMQShortString	QueueBindBody.getRoutingKey()
AMQShortString	MessagePublishInfo.getRoutingKey()
AMQShortString	ExchangeBoundBody.getRoutingKey()
AMQShortString	BasicReturnBody.getRoutingKey()
AMQShortString	BasicPublishBody.getRoutingKey()
AMQShortString	BasicGetOkBody.getRoutingKey()
AMQShortString	BasicDeliverBody.getRoutingKey()
AMQShortString	ExchangeDeclareBody.getType()
AMQShortString	BasicContentHeaderProperties.getType()
AMQShortString	BasicContentHeaderProperties.getUserId()
AMQShortString	ConnectionOpenBody.getVirtualHost()

Methods in org.apache.qpid.server.protocol.v0_8.transport with parameters of type AMQShortString

Modifier and Type	Method and Description
AccessRequestBody	MethodRegistry.createAccessRequestBody(AMQShortString realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read)
BasicCancelBody	MethodRegistry.createBasicCancelBody(AMQShortString consumerTag, boolean nowait)
BasicCancelOkBody	MethodRegistry.createBasicCancelOkBody(AMQShortString consumerTag)
BasicConsumeOkBody	MethodRegistry.createBasicConsumeOkBody(AMQShortString consumerTag)
BasicDeliverBody	MethodRegistry.createBasicDeliverBody(AMQShortString consumerTag, long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey)
BasicGetBody	MethodRegistry.createBasicGetBody(int ticket, AMQShortString queue, boolean noAck)
BasicGetEmptyBody	MethodRegistry.createBasicGetEmptyBody(AMQShortString clusterId)
BasicGetOkBody	MethodRegistry.createBasicGetOkBody(long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey, long messageCount)
BasicReturnBody	MethodRegistry.createBasicReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
ChannelAlertBody	MethodRegistry.createChannelAlertBody(int replyCode, AMQShortString replyText, FieldTable details)
ChannelCloseBody	MethodRegistry.createChannelCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
ChannelOpenBody	MethodRegistry.createChannelOpenBody(AMQShortString outOfBand)
ConnectionCloseBody	MethodRegistry.createConnectionCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
ConnectionOpenBody	MethodRegistry.createConnectionOpenBody(AMQShortString virtualHost, AMQShortString capabilities, boolean insist)
ConnectionOpenOkBody	MethodRegistry.createConnectionOpenOkBody(AMQShortString knownHosts)
ConnectionRedirectBody	MethodRegistry.createConnectionRedirectBody(AMQShortString host, AMQShortString knownHosts)
ConnectionStartOkBody	MethodRegistry.createConnectionStartOkBody(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
ExchangeBoundOkBody	MethodRegistry.createExchangeBoundOkBody(int replyCode, AMQShortString replyText)
QueueDeclareOkBody	MethodRegistry.createQueueDeclareOkBody(AMQShortString queue, long messageCount, long consumerCount)
QueuePurgeBody	MethodRegistry.createQueuePurgeBody(int ticket, AMQShortString queue, boolean nowait)
QueueUnbindBody	MethodRegistry.createQueueUnbindBody(int ticket, AMQShortString queue, AMQShortString exchange, AMQShortString routingKey, FieldTable arguments)
protected int	AMQMethodBodyImpl.getSizeOf(AMQShortString string)
void	ServerChannelMethodProcessor.receiveAccessRequest(AMQShortString realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read)
void	ServerChannelMethodProcessor.receiveBasicCancel(AMQShortString consumerTag, boolean noWait)
void	ClientChannelMethodProcessor.receiveBasicCancelOk(AMQShortString consumerTag)
void	ServerChannelMethodProcessor.receiveBasicConsume(AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, FieldTable arguments)
void	ClientChannelMethodProcessor.receiveBasicConsumeOk(AMQShortString consumerTag)
void	ClientChannelMethodProcessor.receiveBasicDeliver(AMQShortString consumerTag, long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey)
void	ServerChannelMethodProcessor.receiveBasicGet(AMQShortString queue, boolean noAck)
void	ClientChannelMethodProcessor.receiveBasicGetOk(long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey, long messageCount)
void	ServerChannelMethodProcessor.receiveBasicPublish(AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate)
void	ClientChannelMethodProcessor.receiveBasicReturn(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
void	ClientChannelMethodProcessor.receiveChannelAlert(int replyCode, AMQShortString replyText, FieldTable details)
void	ChannelMethodProcessor.receiveChannelClose(int replyCode, AMQShortString replyText, int classId, int methodId)
void	MethodProcessor.receiveConnectionClose(int replyCode, AMQShortString replyText, int classId, int methodId)
void	FrameCreatingMethodProcessor.receiveConnectionClose(int replyCode, AMQShortString replyText, int classId, int methodId)
void	ServerMethodProcessor.receiveConnectionOpen(AMQShortString virtualHost, AMQShortString capabilities, boolean insist)
void	FrameCreatingMethodProcessor.receiveConnectionOpen(AMQShortString virtualHost, AMQShortString capabilities, boolean insist)
void	FrameCreatingMethodProcessor.receiveConnectionOpenOk(AMQShortString knownHosts)
void	ClientMethodProcessor.receiveConnectionOpenOk(AMQShortString knownHosts)
void	FrameCreatingMethodProcessor.receiveConnectionRedirect(AMQShortString host, AMQShortString knownHosts)
void	ClientMethodProcessor.receiveConnectionRedirect(AMQShortString host, AMQShortString knownHosts)
void	ServerMethodProcessor.receiveConnectionStartOk(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
void	FrameCreatingMethodProcessor.receiveConnectionStartOk(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
void	ServerChannelMethodProcessor.receiveExchangeBound(AMQShortString exchange, AMQShortString routingKey, AMQShortString queue)
void	ClientChannelMethodProcessor.receiveExchangeBoundOk(int replyCode, AMQShortString replyText)
void	ServerChannelMethodProcessor.receiveExchangeDeclare(AMQShortString exchange, AMQShortString type, boolean passive, boolean durable, boolean autoDelete, boolean internal, boolean nowait, FieldTable arguments)
void	ServerChannelMethodProcessor.receiveExchangeDelete(AMQShortString exchange, boolean ifUnused, boolean nowait)
void	ServerChannelMethodProcessor.receiveQueueBind(AMQShortString queue, AMQShortString exchange, AMQShortString bindingKey, boolean nowait, FieldTable arguments)
void	ServerChannelMethodProcessor.receiveQueueDeclare(AMQShortString queue, boolean passive, boolean durable, boolean exclusive, boolean autoDelete, boolean nowait, FieldTable arguments)
void	ClientChannelMethodProcessor.receiveQueueDeclareOk(AMQShortString queue, long messageCount, long consumerCount)
void	ServerChannelMethodProcessor.receiveQueueDelete(AMQShortString queue, boolean ifUnused, boolean ifEmpty, boolean nowait)
void	ServerChannelMethodProcessor.receiveQueuePurge(AMQShortString queue, boolean nowait)
void	ServerChannelMethodProcessor.receiveQueueUnbind(AMQShortString queue, AMQShortString exchange, AMQShortString bindingKey, FieldTable arguments)
void	BasicContentHeaderProperties.setAppId(AMQShortString appId)
void	BasicContentHeaderProperties.setClusterId(AMQShortString clusterId)
void	BasicContentHeaderProperties.setContentType(AMQShortString contentType)
void	BasicContentHeaderProperties.setCorrelationId(AMQShortString correlationId)
void	BasicContentHeaderProperties.setEncoding(AMQShortString encoding)
void	MessagePublishInfo.setExchange(AMQShortString exchange)
void	BasicContentHeaderProperties.setMessageId(AMQShortString messageId)
void	BasicContentHeaderProperties.setReplyTo(AMQShortString replyTo)
void	MessagePublishInfo.setRoutingKey(AMQShortString routingKey)
void	BasicContentHeaderProperties.setType(AMQShortString type)
void	BasicContentHeaderProperties.setUserId(AMQShortString userId)
protected void	AMQMethodBodyImpl.writeAMQShortString(QpidByteBuffer buffer, AMQShortString string)

Constructors in org.apache.qpid.server.protocol.v0_8.transport with parameters of type AMQShortString

Constructor and Description
AccessRequestBody(AMQShortString realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read)
BasicCancelBody(AMQShortString consumerTag, boolean nowait)
BasicCancelOkBody(AMQShortString consumerTag)
BasicConsumeBody(int ticket, AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, FieldTable arguments)
BasicConsumeOkBody(AMQShortString consumerTag)
BasicDeliverBody(AMQShortString consumerTag, long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey)
BasicGetBody(int ticket, AMQShortString queue, boolean noAck)
BasicGetEmptyBody(AMQShortString clusterId)
BasicGetOkBody(long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey, long messageCount)
BasicPublishBody(int ticket, AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate)
BasicReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
ChannelAlertBody(int replyCode, AMQShortString replyText, FieldTable details)
ChannelCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
ConnectionCloseBody(ProtocolVersion protocolVersion, int replyCode, AMQShortString replyText, int classId, int methodId)
ConnectionOpenBody(AMQShortString virtualHost, AMQShortString capabilities, boolean insist)
ConnectionOpenOkBody(AMQShortString knownHosts)
ConnectionRedirectBody(ProtocolVersion protocolVersion, AMQShortString host, AMQShortString knownHosts)
ConnectionStartOkBody(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
ExchangeBoundBody(AMQShortString exchange, AMQShortString routingKey, AMQShortString queue)
ExchangeBoundOkBody(int replyCode, AMQShortString replyText)
ExchangeDeclareBody(int ticket, AMQShortString exchange, AMQShortString type, boolean passive, boolean durable, boolean autoDelete, boolean internal, boolean nowait, FieldTable arguments)
ExchangeDeleteBody(int ticket, AMQShortString exchange, boolean ifUnused, boolean nowait)
MessagePublishInfo(AMQShortString exchange, boolean immediate, boolean mandatory, AMQShortString routingKey)
QueueBindBody(int ticket, AMQShortString queue, AMQShortString exchange, AMQShortString routingKey, boolean nowait, FieldTable arguments)
QueueDeclareBody(int ticket, AMQShortString queue, boolean passive, boolean durable, boolean exclusive, boolean autoDelete, boolean nowait, FieldTable arguments)
QueueDeclareOkBody(AMQShortString queue, long messageCount, long consumerCount)
QueueDeleteBody(int ticket, AMQShortString queue, boolean ifUnused, boolean ifEmpty, boolean nowait)
QueuePurgeBody(int ticket, AMQShortString queue, boolean nowait)
QueueUnbindBody(int ticket, AMQShortString queue, AMQShortString exchange, AMQShortString routingKey, FieldTable arguments)