Package | Description |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.failover | |
org.apache.qpid.client.protocol | |
org.apache.qpid.ra | |
org.apache.qpid.testkit |
Modifier and Type | Class and Description |
---|---|
class |
XAConnectionImpl
This class implements the javax.jms.XAConnection interface
|
Modifier and Type | Method and Description |
---|---|
AMQConnection |
AMQConnectionFactory.createConnection() |
AMQConnection |
AMQConnectionFactory.createConnection(String userName,
String password) |
AMQConnection |
AMQConnectionFactory.createConnection(String userName,
String password,
String id) |
AMQConnection |
AMQSession.getAMQConnection() |
protected AMQConnection |
BasicMessageConsumer.getConnection()
The connection being used by this consumer
|
protected AMQConnection |
BasicMessageProducer.getConnection() |
AMQConnection |
AMQProtocolHandler.getConnection() |
Modifier and Type | Method and Description |
---|---|
static AMQTopic |
AMQTopic.createDurableTopic(javax.jms.Topic topic,
String subscriptionName,
AMQConnection connection) |
static String |
AMQTopic.getDurableTopicQueueName(String subscriptionName,
AMQConnection connection) |
Constructor and Description |
---|
AMQConnectionDelegate_0_10(AMQConnection conn) |
AMQConnectionDelegate_0_9(AMQConnection conn) |
AMQConnectionDelegate_0_91(AMQConnection conn) |
AMQConnectionDelegate_8_0(AMQConnection conn) |
AMQProtocolHandler(AMQConnection con)
Creates a new protocol handler, associated with the specified client connection instance.
|
AMQQueue(AMQConnection connection,
String name) |
AMQQueue(AMQConnection connection,
String name,
boolean temporary) |
AMQSession_0_8(AMQConnection con,
int channelId,
boolean transacted,
int acknowledgeMode,
int defaultPrefetchHighMark,
int defaultPrefetchLowMark)
Creates a new session on a connection.
|
AMQSession(AMQConnection con,
int channelId,
boolean transacted,
int acknowledgeMode,
int defaultPrefetchHighMark,
int defaultPrefetchLowMark)
Creates a new session on a connection.
|
AMQTopic(AMQConnection conn,
String routingKey) |
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) |
XASessionImpl(Connection qpidConnection,
AMQConnection con,
int channelId,
boolean transacted,
int ackMode,
int defaultPrefetchHigh,
int defaultPrefetchLow,
String name) |
XASessionImpl(Connection qpidConnection,
AMQConnection con,
int channelId,
int defaultPrefetchHigh,
int defaultPrefetchLow)
Create a JMS XASession
|
XASessionImpl(Connection qpidConnection,
AMQConnection con,
int channelId,
int ackMode,
int defaultPrefetchHigh,
int defaultPrefetchLow) |
Constructor and Description |
---|
FailoverNoopSupport(FailoverProtectedOperation<T,E> operation,
AMQConnection con)
Creates an automatic retrying fail-over handler for the specified operation.
|
FailoverRetrySupport(FailoverProtectedOperation<T,E> operation,
AMQConnection con)
Creates an automatic retrying fail-over handler for the specified operation.
|
Modifier and Type | Method and Description |
---|---|
AMQConnection |
AMQProtocolSession.getAMQConnection() |
protected AMQConnection |
AMQProtocolSession.getConnection() |
Constructor and Description |
---|
AMQProtocolSession(AMQProtocolHandler protocolHandler,
AMQConnection connection) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Session |
QpidResourceAdapter.createSession(AMQConnection connection,
int ackMode,
boolean useLocalTx,
Integer prefetchLow,
Integer prefetchHigh) |
Modifier and Type | Field and Description |
---|---|
protected AMQConnection |
TestLauncher.controlCon |
Modifier and Type | Field and Description |
---|---|
protected List<AMQConnection> |
TestLauncher.clients |
Modifier and Type | Method and Description |
---|---|
protected void |
TestLauncher.createReceiver(String index,
AMQConnection con,
String addr,
ErrorHandler h) |
protected void |
TestLauncher.createSender(String index,
AMQConnection con,
String addr,
ErrorHandler h) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.