|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AMQConnection | |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.failover | |
org.apache.qpid.client.protocol | |
org.apache.qpid.jms | |
org.apache.qpid.jms.failover |
Uses of AMQConnection in org.apache.qpid.client |
---|
Subclasses of AMQConnection in org.apache.qpid.client | |
---|---|
class |
XAConnectionImpl
This class implements the javax.njms.XAConnection interface |
Fields in org.apache.qpid.client declared as AMQConnection | |
---|---|
protected AMQConnection |
AMQSession._connection
The connection to which this session belongs. |
protected AMQConnection |
BasicMessageConsumer._connection
The connection being used by this consumer |
Methods in org.apache.qpid.client that return AMQConnection | |
---|---|
AMQConnection |
AMQSession.getAMQConnection()
|
Methods in org.apache.qpid.client with parameters of type AMQConnection | |
---|---|
static AMQTopic |
AMQTopic.createDurableTopic(AMQTopic topic,
String subscriptionName,
AMQConnection connection)
|
static org.apache.qpid.framing.AMQShortString |
AMQTopic.getDurableTopicQueueName(String subscriptionName,
AMQConnection connection)
|
Constructors in org.apache.qpid.client with parameters of type AMQConnection | |
---|---|
AMQConnectionDelegate_0_10(AMQConnection conn)
|
|
AMQConnectionDelegate_0_9(AMQConnection conn)
|
|
AMQConnectionDelegate_8_0(AMQConnection conn)
|
|
AMQConnectionDelegate_9_1(AMQConnection conn)
|
|
AMQQueue(AMQConnection connection,
String name)
|
|
AMQQueue(AMQConnection connection,
String name,
boolean temporary)
|
|
AMQSession_0_10(org.apache.qpid.transport.Connection qpidConnection,
AMQConnection con,
int channelId,
boolean transacted,
int acknowledgeMode,
int defaultPrefetchHigh,
int defaultPrefetchLow)
Creates a new session on a connection with the default 0-10 message factory. |
|
AMQSession_0_10(org.apache.qpid.transport.Connection qpidConnection,
AMQConnection con,
int channelId,
boolean transacted,
int acknowledgeMode,
MessageFactoryRegistry messageFactoryRegistry,
int defaultPrefetchHighMark,
int defaultPrefetchLowMark)
Creates a new session on a connection. |
|
AMQSession_0_8(AMQConnection con,
int channelId,
boolean transacted,
int acknowledgeMode,
int defaultPrefetchHigh,
int defaultPrefetchLow)
Creates a new session on a connection with the default message factory factory. |
|
AMQSession_0_8(AMQConnection con,
int channelId,
boolean transacted,
int acknowledgeMode,
MessageFactoryRegistry messageFactoryRegistry,
int defaultPrefetchHighMark,
int defaultPrefetchLowMark)
Creates a new session on a connection. |
|
AMQSession(AMQConnection con,
int channelId,
boolean transacted,
int acknowledgeMode,
int defaultPrefetchHigh,
int defaultPrefetchLow)
Creates a new session on a connection with the default message factory factory. |
|
AMQSession(AMQConnection con,
int channelId,
boolean transacted,
int acknowledgeMode,
MessageFactoryRegistry messageFactoryRegistry,
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,
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)
|
|
QpidConnectionMetaData(AMQConnection conn)
|
|
XASessionImpl(org.apache.qpid.transport.Connection qpidConnection,
AMQConnection con,
int channelId,
int defaultPrefetchHigh,
int defaultPrefetchLow)
Create a JMS XASession |
Uses of AMQConnection in org.apache.qpid.client.failover |
---|
Fields in org.apache.qpid.client.failover declared as AMQConnection | |
---|---|
(package private) AMQConnection |
FailoverNoopSupport.connection
The connection on which the fail-over protected operation is to be performed. |
(package private) AMQConnection |
FailoverRetrySupport.connection
The connection on which the fail-over protected operation is to be performed. |
Constructors in org.apache.qpid.client.failover with parameters of type AMQConnection | |
---|---|
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. |
Uses of AMQConnection in org.apache.qpid.client.protocol |
---|
Fields in org.apache.qpid.client.protocol declared as AMQConnection | |
---|---|
protected AMQConnection |
AMQProtocolSession._connection
|
Methods in org.apache.qpid.client.protocol that return AMQConnection | |
---|---|
AMQConnection |
AMQProtocolSession.getAMQConnection()
|
AMQConnection |
AMQProtocolHandler.getConnection()
|
Constructors in org.apache.qpid.client.protocol with parameters of type AMQConnection | |
---|---|
AMQProtocolHandler(AMQConnection con)
Creates a new protocol handler, associated with the specified client connection instance. |
|
AMQProtocolSession(AMQProtocolHandler protocolHandler,
AMQConnection connection)
|
Uses of AMQConnection in org.apache.qpid.jms |
---|
Constructors in org.apache.qpid.jms with parameters of type AMQConnection | |
---|---|
FailoverPolicy(ConnectionURL connectionDetails,
AMQConnection conn)
|
Uses of AMQConnection in org.apache.qpid.jms.failover |
---|
Constructors in org.apache.qpid.jms.failover with parameters of type AMQConnection | |
---|---|
FailoverExchangeMethod(ConnectionURL connectionDetails,
AMQConnection conn)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |