See: Description
| Interface | Description |
|---|---|
| ChannelListener |
A listener for new channel creation and destruction.
|
| ChannelProxy |
Subinterface of
Channel to be implemented by
Channel proxies. |
| Connection | |
| ConnectionFactory |
An interface based ConnectionFactory for creating
Connections. |
| ConnectionFactoryUtils.ResourceFactory |
Callback interface for resource creation.
|
| ConnectionListener |
A listener for connection creation and closing.
|
| ConnectionNameStrategy |
A strategy to build an application-specific connection name,
which can be displayed in the management UI if RabbitMQ server supports it.
|
| ConnectionProxy |
Subinterface of
Connection to be implemented by
Connection proxies. |
| PublisherCallbackChannel |
Instances of this interface support a single listener being
registered for publisher confirms with multiple channels,
by adding context to the callbacks.
|
| PublisherCallbackChannel.Listener |
Listeners implementing this interface can participate
in publisher confirms received from multiple channels,
by invoking addListener on each channel.
|
| PublisherCallbackChannelConnectionFactory | Deprecated
in favor of default methods on ConnectionFactory.
|
| PublisherCallbackChannelFactory |
A factory for
PublisherCallbackChannels. |
| RoutingConnectionFactory |
Implementations select a connection factory based on a supplied key.
|
| ShutDownChannelListener |
Functional sub interface enabling a lambda for the onShutDown method.
|
| Class | Description |
|---|---|
| AbstractConnectionFactory | |
| AbstractRoutingConnectionFactory |
Abstract
ConnectionFactory implementation that routes AbstractRoutingConnectionFactory.createConnection()
calls to one of various target ConnectionFactories based on a lookup key. |
| CachingConnectionFactory |
A
ConnectionFactory implementation that (when the cache mode is CachingConnectionFactory.CacheMode.CHANNEL (default)
returns the same Connection from all CachingConnectionFactory.createConnection()
calls, and ignores calls to Connection.close() and caches
Channel. |
| ClosingRecoveryListener |
A
RecoveryListener that closes the recovered channel, to avoid
orphaned consumers. |
| CompositeChannelListener | |
| CompositeConnectionListener | |
| ConnectionBlockedEvent |
The
AmqpEvent emitted by the CachingConnectionFactory
when its connections are blocked. |
| ConnectionFactoryConfigurationUtils |
Utility methods for configuring connection factories.
|
| ConnectionFactoryUtils |
Helper class for managing a Spring based Rabbit
ConnectionFactory,
in particular for obtaining transactional Rabbit resources for a given ConnectionFactory. |
| ConnectionUnblockedEvent |
The
AmqpEvent emitted by the CachingConnectionFactory
when its connections are unblocked. |
| ConsumerChannelRegistry |
Consumers register their primary channels with this class.
|
| CorrelationData |
Base class for correlating publisher confirms to sent messages.
|
| CorrelationData.Confirm |
Represents a publisher confirmation.
|
| LocalizedQueueConnectionFactory |
A
RoutingConnectionFactory that determines the node on which a queue is located and
returns a factory that connects directly to that node. |
| PendingConfirm |
Instances of this object track pending publisher confirms.
|
| PublisherCallbackChannelImpl |
Channel wrapper to allow a single listener able to handle
confirms from multiple channels.
|
| RabbitAccessor | |
| RabbitConnectionFactoryBean |
Factory bean to create a RabbitMQ ConnectionFactory, delegating most setter methods and
optionally enabling SSL, with or without certificate validation.
|
| RabbitResourceHolder |
Rabbit resource holder, wrapping a RabbitMQ Connection and Channel.
|
| RabbitUtils | |
| SimpleConnection |
Simply a Connection.
|
| SimplePropertyValueConnectionNameStrategy |
A
ConnectionNameStrategy that returns the value of a (required) property. |
| SimpleResourceHolder |
Central helper that manages resources per thread to be used by resource management code.
|
| SimpleRoutingConnectionFactory |
An
AbstractRoutingConnectionFactory implementation which gets a lookupKey
for current ConnectionFactory from thread-bound resource by key of the instance of
this ConnectionFactory. |
| Enum | Description |
|---|---|
| CachingConnectionFactory.CacheMode |
The cache mode.
|
| Exception | Description |
|---|---|
| AutoRecoverConnectionNotCurrentlyOpenException |
An exception thrown if the connection is an auto recover connection that is not
currently open and is in the process of being recovered.
|