Package | Description |
---|---|
org.apache.qpid.jms |
The core AMQP JMS client implementation classes.
|
org.apache.qpid.jms.provider | |
org.apache.qpid.jms.provider.amqp | |
org.apache.qpid.jms.provider.discovery | |
org.apache.qpid.jms.provider.failover |
Modifier and Type | Method and Description |
---|---|
protected Provider |
JmsConnectionFactory.createProvider(URI remoteURI) |
Modifier and Type | Method and Description |
---|---|
protected void |
JmsMessageConsumer.onConnectionRecovered(Provider provider) |
protected void |
JmsMessageProducer.onConnectionRecovered(Provider provider) |
protected void |
JmsSession.onConnectionRecovered(Provider provider) |
void |
JmsConnection.onConnectionRecovered(Provider provider) |
void |
JmsTransactionContext.onConnectionRecovery(Provider provider)
Called when the connection to the remote peer has been lost and then a new
connection established.
|
protected void |
JmsMessageConsumer.onConnectionRecovery(Provider provider) |
void |
JmsNoTxTransactionContext.onConnectionRecovery(Provider provider) |
protected void |
JmsMessageProducer.onConnectionRecovery(Provider provider) |
void |
JmsLocalTransactionContext.onConnectionRecovery(Provider provider) |
protected void |
JmsSession.onConnectionRecovery(Provider provider) |
void |
JmsConnection.onConnectionRecovery(Provider provider) |
Constructor and Description |
---|
JmsConnection(String connectionId,
Provider provider,
IdGenerator clientIdGenerator) |
JmsQueueConnection(String connectionId,
Provider provider,
IdGenerator clientIdGenerator) |
JmsTopicConnection(String connectionId,
Provider provider,
IdGenerator clientIdGenerator) |
Modifier and Type | Class and Description |
---|---|
class |
ProviderWrapper<E extends Provider>
|
Modifier and Type | Class and Description |
---|---|
class |
ProviderWrapper<E extends Provider>
|
Modifier and Type | Field and Description |
---|---|
protected E |
ProviderWrapper.next |
Modifier and Type | Method and Description |
---|---|
static Provider |
ProviderFactory.create(URI remoteURI)
Static create method that performs the ProviderFactory search and handles the
configuration and setup.
|
abstract Provider |
ProviderFactory.createProvider(URI remoteURI)
Creates an instance of the given AsyncProvider and configures it using the
properties set on the given remote broker URI.
|
Provider |
ProviderWrapper.getNext() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultProviderListener.onConnectionRecovered(Provider provider) |
void |
ProviderWrapper.onConnectionRecovered(Provider provider) |
void |
ProviderListener.onConnectionRecovered(Provider provider)
Called to indicate that a connection to the Broker has been reestablished and
that all recovery operations have succeeded and the connection will now be
transitioned to a recovered state.
|
void |
DefaultProviderListener.onConnectionRecovery(Provider provider) |
void |
ProviderWrapper.onConnectionRecovery(Provider provider) |
void |
ProviderListener.onConnectionRecovery(Provider provider)
Called to indicate that a connection to the Broker has been reestablished and
that notified listener should start to recover it's state.
|
Modifier and Type | Class and Description |
---|---|
class |
AmqpProvider
An AMQP v1.0 Provider.
|
Modifier and Type | Method and Description |
---|---|
Provider |
AmqpProviderFactory.createProvider(URI remoteURI) |
Modifier and Type | Class and Description |
---|---|
class |
DiscoveryProvider
An Provider instance that wraps the FailoverProvider and listens for events
about discovered remote peers using a configured set of DiscoveryAgent instance.
|
Modifier and Type | Method and Description |
---|---|
Provider |
DiscoveryProviderFactory.createProvider(URI remoteURI) |
Modifier and Type | Class and Description |
---|---|
class |
FailoverProvider
A Provider Facade that provides services for detection dropped Provider connections
and attempting to reconnect to a different remote peer.
|
Modifier and Type | Method and Description |
---|---|
Provider |
FailoverProviderFactory.createProvider(URI remoteURI) |
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.