Package | Description |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.message | |
org.apache.qpid.ra.admin |
Modifier and Type | Class and Description |
---|---|
static class |
AMQSession_0_8.DestinationCache<T extends AMQDestination> |
Modifier and Type | Class and Description |
---|---|
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 |
class |
AMQTopic |
class |
AMQUndefinedDestination |
Modifier and Type | Method and Description |
---|---|
AMQDestination |
AMQDestination.copyDestination() |
protected AMQDestination |
BasicMessageProducer.getAMQDestination() |
AMQDestination |
BasicMessageConsumer.getDestination() |
Modifier and Type | Method and Description |
---|---|
void |
BasicMessageConsumer.addBindingKey(AMQDestination amqd,
String routingKey) |
void |
AMQSession.addBindingKey(C consumer,
AMQDestination amqd,
String routingKey) |
void |
AMQSession.bindQueue(String queueName,
String routingKey,
Map<String,Object> arguments,
String exchangeName,
AMQDestination destination)
Binds the named queue, with the specified routing key, to the named exchange.
|
void |
AMQSession.bindQueue(String queueName,
String routingKey,
Map<String,Object> arguments,
String exchangeName,
AMQDestination destination,
boolean nowait) |
BasicMessageConsumer_0_8 |
AMQSession_0_8.createMessageConsumer(AMQDestination destination,
int prefetchHigh,
int prefetchLow,
boolean noLocal,
boolean exclusive,
String messageSelector,
Map<String,Object> arguments,
boolean noConsume,
boolean autoClose) |
BasicMessageConsumer_0_10 |
AMQSession_0_10.createMessageConsumer(AMQDestination destination,
int prefetchHigh,
int prefetchLow,
boolean noLocal,
boolean exclusive,
String messageSelector,
Map<String,Object> rawSelector,
boolean noConsume,
boolean autoClose)
Create an 0_10 message consumer
|
abstract C |
AMQSession.createMessageConsumer(AMQDestination destination,
int prefetchHigh,
int prefetchLow,
boolean noLocal,
boolean exclusive,
String selector,
Map<String,Object> arguments,
boolean noConsume,
boolean autoClose) |
void |
AMQSession.declareAndBind(AMQDestination amqd) |
void |
AMQSession.declareAndBind(AMQDestination amqd,
Map<String,Object> arguments) |
protected String |
AMQSession.declareQueue(AMQDestination amqd,
boolean noLocal)
Declares a queue for a JMS destination.
|
protected String |
AMQSession.declareQueue(AMQDestination amqd,
boolean noLocal,
boolean nowait) |
protected String |
AMQSession_0_8.declareQueue(AMQDestination amqd,
boolean noLocal,
boolean nowait,
boolean passive) |
protected String |
AMQSession_0_10.declareQueue(AMQDestination amqd,
boolean noLocal,
boolean nowait,
boolean passive) |
protected abstract String |
AMQSession.declareQueue(AMQDestination amqd,
boolean noLocal,
boolean nowait,
boolean passive) |
protected void |
AMQSession_0_8.doBind(AMQDestination dest,
AMQDestination.Binding binding,
String queue,
String exchange) |
protected void |
AMQSession_0_10.doBind(AMQDestination dest,
AMQDestination.Binding binding,
String queue,
String exchange) |
protected abstract void |
AMQSession.doBind(AMQDestination dest,
AMQDestination.Binding binding,
String queue,
String exchange) |
long |
AMQSession.getQueueDepth(AMQDestination amqd)
Returns the number of messages currently queued for the given destination.
|
long |
AMQSession.getQueueDepth(AMQDestination amqd,
boolean sync)
Returns the number of messages currently queued by the given
destination.
|
protected void |
AMQSession_0_8.handleQueueNodeCreation(AMQDestination dest,
boolean noLocal) |
protected void |
AMQSession_0_10.handleQueueNodeCreation(AMQDestination dest,
boolean noLocal) |
protected abstract void |
AMQSession.handleQueueNodeCreation(AMQDestination dest,
boolean noLocal) |
boolean |
BasicMessageProducer.isBound(AMQDestination destination) |
boolean |
BasicMessageProducer_0_10.isBound(AMQDestination destination) |
boolean |
AMQSession_0_8.isExchangeExist(AMQDestination dest,
boolean assertNode) |
boolean |
AMQSession_0_10.isExchangeExist(AMQDestination dest,
boolean assertNode) |
abstract boolean |
AMQSession.isExchangeExist(AMQDestination dest,
boolean assertNode) |
boolean |
AMQSession_0_8.isQueueBound(AMQDestination destination) |
boolean |
AMQSession_0_10.isQueueBound(AMQDestination destination) |
abstract boolean |
AMQSession.isQueueBound(AMQDestination destination) |
boolean |
AMQSession_0_8.isQueueExist(AMQDestination dest,
boolean assertNode) |
boolean |
AMQSession_0_10.isQueueExist(AMQDestination dest,
boolean assertNode) |
abstract boolean |
AMQSession.isQueueExist(AMQDestination dest,
boolean assertNode) |
protected Long |
AMQSession_0_8.requestQueueDepth(AMQDestination amqd,
boolean sync) |
protected Long |
AMQSession_0_10.requestQueueDepth(AMQDestination amqd,
boolean sync) |
protected abstract Long |
AMQSession.requestQueueDepth(AMQDestination amqd,
boolean sync) |
void |
AMQSession_0_8.resolveAddress(AMQDestination dest,
boolean isConsumer,
boolean noLocal) |
void |
AMQSession.resolveAddress(AMQDestination dest,
boolean isConsumer,
boolean noLocal)
1.
|
int |
AMQSession_0_8.resolveAddressType(AMQDestination dest) |
int |
AMQSession_0_10.resolveAddressType(AMQDestination dest) |
abstract int |
AMQSession.resolveAddressType(AMQDestination dest) |
String |
AMQSession_0_10.send0_10QueueDeclare(AMQDestination amqd,
boolean noLocal,
boolean nowait,
boolean passive)
Declare a queue with the given queueName
|
protected void |
BasicMessageProducer.sendImpl(AMQDestination destination,
javax.jms.Message origMessage,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
long deliveryDelay)
The caller of this method must hold the failover mutex.
|
void |
AMQSession_0_8.sendQueueBind(String queueName,
String routingKey,
Map<String,Object> arguments,
String exchangeName,
AMQDestination destination,
boolean nowait) |
void |
AMQSession_0_10.sendQueueBind(String queueName,
String routingKey,
Map<String,Object> arguments,
String exchangeName,
AMQDestination destination,
boolean nowait)
Bind a queue with an exchange.
|
abstract void |
AMQSession.sendQueueBind(String queueName,
String routingKey,
Map<String,Object> arguments,
String exchangeName,
AMQDestination destination,
boolean nowait) |
protected void |
BasicMessageConsumer.setDestination(AMQDestination destination) |
protected void |
BasicMessageProducer.setDestination(AMQDestination destination) |
void |
AMQSession.setLegacyFieldsForQueueType(AMQDestination dest) |
void |
AMQSession.setLegacyFieldsForTopicType(AMQDestination dest) |
protected void |
AMQSession.verifySubject(AMQDestination dest) |
Constructor and Description |
---|
BasicMessageConsumer_0_10(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession<?,?> session,
Map<String,Object> rawSelector,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean browseOnly,
boolean autoClose) |
BasicMessageConsumer_0_8(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession_0_8 session,
Map<String,Object> rawSelector,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean browseOnly,
boolean autoClose) |
BasicMessageConsumer(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
Map<String,Object> rawSelector,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean browseOnly,
boolean autoClose) |
BasicMessageProducer(org.slf4j.Logger logger,
AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
long producerId,
Boolean immediate,
Boolean mandatory) |
Modifier and Type | Method and Description |
---|---|
protected AMQDestination |
AbstractAMQMessageDelegate.generateDestination(String exchange,
String routingKey)
Called when a Destination is requried.
|
Modifier and Type | Class and Description |
---|---|
class |
QpidQueueImpl |
class |
QpidTopicImpl |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.