|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AMQDestination | |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.message |
Uses of AMQDestination in org.apache.qpid.client |
---|
Subclasses of AMQDestination in org.apache.qpid.client | |
---|---|
class |
AMQAnyDestination
In order to support JMS 1.0 the Qpid implementation maps the direct exchange to JMS Queue and topic exchange to JMS Topic. |
class |
AMQHeadersExchange
A destination backed by a headers exchange |
class |
AMQQueue
|
(package private) class |
AMQTemporaryQueue
AMQ implementation of a TemporaryQueue. |
(package private) class |
AMQTemporaryTopic
AMQ implementation of TemporaryTopic. |
class |
AMQTopic
|
class |
AMQUndefinedDestination
|
Fields in org.apache.qpid.client declared as AMQDestination | |
---|---|
protected AMQDestination |
BasicMessageConsumer._destination
|
protected AMQDestination |
BasicMessageProducer._destination
The Destination used for this consumer, if specified upon creation. |
Methods in org.apache.qpid.client that return AMQDestination | |
---|---|
AMQDestination |
AMQDestination.copyDestination()
|
AMQDestination |
BasicMessageConsumer.getDestination()
|
Methods in org.apache.qpid.client with parameters of type AMQDestination | |
---|---|
void |
BasicMessageConsumer.addBindingKey(AMQDestination amqd,
String routingKey)
|
void |
AMQSession.addBindingKey(C consumer,
AMQDestination amqd,
String routingKey)
|
void |
AMQSession.bindQueue(org.apache.qpid.framing.AMQShortString queueName,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.FieldTable arguments,
org.apache.qpid.framing.AMQShortString exchangeName,
AMQDestination destination)
Binds the named queue, with the specified routing key, to the named exchange. |
void |
AMQSession.bindQueue(org.apache.qpid.framing.AMQShortString queueName,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.FieldTable arguments,
org.apache.qpid.framing.AMQShortString exchangeName,
AMQDestination destination,
boolean nowait)
|
abstract C |
AMQSession.createMessageConsumer(AMQDestination destination,
int prefetchHigh,
int prefetchLow,
boolean noLocal,
boolean exclusive,
String selector,
org.apache.qpid.framing.FieldTable arguments,
boolean noConsume,
boolean autoClose)
|
BasicMessageConsumer_0_10 |
AMQSession_0_10.createMessageConsumer(AMQDestination destination,
int prefetchHigh,
int prefetchLow,
boolean noLocal,
boolean exclusive,
String messageSelector,
org.apache.qpid.framing.FieldTable ft,
boolean noConsume,
boolean autoClose)
Create an 0_10 message consumer |
BasicMessageConsumer_0_8 |
AMQSession_0_8.createMessageConsumer(AMQDestination destination,
int prefetchHigh,
int prefetchLow,
boolean noLocal,
boolean exclusive,
String messageSelector,
org.apache.qpid.framing.FieldTable arguments,
boolean noConsume,
boolean autoClose)
|
void |
AMQSession.declareAndBind(AMQDestination amqd)
|
(package private) abstract void |
BasicMessageProducer.declareDestination(AMQDestination destination)
|
(package private) void |
BasicMessageProducer_0_10.declareDestination(AMQDestination destination)
|
(package private) void |
BasicMessageProducer_0_8.declareDestination(AMQDestination destination)
|
protected org.apache.qpid.framing.AMQShortString |
AMQSession.declareQueue(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean noLocal)
Declares a queue for a JMS destination. |
protected org.apache.qpid.framing.AMQShortString |
AMQSession.declareQueue(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean noLocal,
boolean nowait)
|
protected org.apache.qpid.framing.AMQShortString |
AMQSession_0_10.declareQueue(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean noLocal,
boolean nowait)
|
long |
AMQSession.getQueueDepth(AMQDestination amqd)
Returns the number of messages currently queued for the given destination. |
abstract void |
AMQSession.handleAddressBasedDestination(AMQDestination dest,
boolean isConsumer,
boolean noWait)
|
void |
AMQSession_0_10.handleAddressBasedDestination(AMQDestination dest,
boolean isConsumer,
boolean noWait)
1. |
void |
AMQSession_0_8.handleAddressBasedDestination(AMQDestination dest,
boolean isConsumer,
boolean noWait)
|
boolean |
BasicMessageProducer.isBound(AMQDestination destination)
|
boolean |
BasicMessageProducer_0_10.isBound(AMQDestination destination)
|
boolean |
AMQSession_0_10.isExchangeExist(AMQDestination dest,
Node.ExchangeNode node,
boolean assertNode)
|
abstract boolean |
AMQSession.isQueueBound(AMQDestination destination)
|
boolean |
AMQSession_0_10.isQueueBound(AMQDestination destination)
|
boolean |
AMQSession_0_8.isQueueBound(AMQDestination destination)
|
boolean |
AMQSession_0_10.isQueueExist(AMQDestination dest,
Node.QueueNode node,
boolean assertNode)
|
protected abstract Long |
AMQSession.requestQueueDepth(AMQDestination amqd)
|
protected Long |
AMQSession_0_10.requestQueueDepth(AMQDestination amqd)
|
protected Long |
AMQSession_0_8.requestQueueDepth(AMQDestination amqd)
|
int |
AMQSession_0_10.resolveAddressType(AMQDestination dest)
|
org.apache.qpid.framing.AMQShortString |
AMQSession_0_10.send0_10QueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean noLocal,
boolean nowait)
Declare a queue with the given queueName |
protected void |
BasicMessageProducer.sendImpl(AMQDestination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate)
|
protected void |
BasicMessageProducer.sendImpl(AMQDestination destination,
Message origMessage,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean wait)
The caller of this method must hold the failover mutex. |
(package private) abstract void |
BasicMessageProducer.sendMessage(AMQDestination destination,
Message origMessage,
AbstractJMSMessage message,
UUID messageId,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean wait)
|
(package private) void |
BasicMessageProducer_0_10.sendMessage(AMQDestination destination,
Message origMessage,
AbstractJMSMessage message,
UUID messageId,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean wait)
Sends a message to a given destination |
(package private) void |
BasicMessageProducer_0_8.sendMessage(AMQDestination destination,
Message origMessage,
AbstractJMSMessage message,
UUID messageId,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean wait)
|
abstract void |
AMQSession.sendQueueBind(org.apache.qpid.framing.AMQShortString queueName,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.FieldTable arguments,
org.apache.qpid.framing.AMQShortString exchangeName,
AMQDestination destination,
boolean nowait)
|
void |
AMQSession_0_10.sendQueueBind(org.apache.qpid.framing.AMQShortString queueName,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.FieldTable arguments,
org.apache.qpid.framing.AMQShortString exchangeName,
AMQDestination destination,
boolean nowait)
Bind a queue with an exchange. |
void |
AMQSession_0_8.sendQueueBind(org.apache.qpid.framing.AMQShortString queueName,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.FieldTable arguments,
org.apache.qpid.framing.AMQShortString exchangeName,
AMQDestination dest,
boolean nowait)
|
abstract void |
AMQSession.sendQueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
void |
AMQSession_0_10.sendQueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean nowait)
Declare a queue with the given queueName |
void |
AMQSession_0_8.sendQueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
void |
AMQSession_0_10.setLegacyFiledsForQueueType(AMQDestination dest)
|
void |
AMQSession_0_10.setLegacyFiledsForTopicType(AMQDestination dest)
|
Constructors in org.apache.qpid.client with parameters of type AMQDestination | |
---|---|
BasicMessageConsumer_0_10(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
AMQProtocolHandler protocolHandler,
org.apache.qpid.framing.FieldTable arguments,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean noConsume,
boolean autoClose)
|
|
BasicMessageConsumer_0_8(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
AMQProtocolHandler protocolHandler,
org.apache.qpid.framing.FieldTable arguments,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean noConsume,
boolean autoClose)
|
|
BasicMessageConsumer(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
AMQProtocolHandler protocolHandler,
org.apache.qpid.framing.FieldTable arguments,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean noConsume,
boolean autoClose)
|
|
BasicMessageProducer_0_10(AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
AMQProtocolHandler protocolHandler,
long producerId,
boolean immediate,
boolean mandatory,
boolean waitUntilSent)
|
|
BasicMessageProducer_0_8(AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
AMQProtocolHandler protocolHandler,
long producerId,
boolean immediate,
boolean mandatory,
boolean waitUntilSent)
|
|
BasicMessageProducer(AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
AMQProtocolHandler protocolHandler,
long producerId,
boolean immediate,
boolean mandatory,
boolean waitUntilSent)
|
Uses of AMQDestination in org.apache.qpid.client.message |
---|
Methods in org.apache.qpid.client.message that return AMQDestination | |
---|---|
protected AMQDestination |
AbstractAMQMessageDelegate.generateDestination(org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey)
Called when a Destination is requried. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |