@NonNullApi

Package org.springframework.amqp.rabbit.connection

Provides classes related to connections.

Interface Summary

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.
LocalizedQueueConnectionFactory.FactoryFinder	Callback to determine the connection factory using the provided information.
LocalizedQueueConnectionFactory.NodeLocator<T>	Used to obtain a connection factory for the queue leader.
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.
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 Summary

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	A composite listener that invokes its delegages in turn.
ConnectionBlockedEvent	The AmqpEvent emitted by the CachingConnectionFactory when its connections are blocked.
ConnectionFactoryConfigurationUtils	Utility methods for configuring connection factories.
ConnectionFactoryContextWrapper	Helper class to handle ConnectionFactory context binding and unbinding when executing instructions.
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.
PooledChannelConnectionFactory	A very simple connection factory that caches channels using Apache Pool2 GenericObjectPools (one for transactional and one for non-transactional channels).
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
RestTemplateNodeLocator	A LocalizedQueueConnectionFactory.NodeLocator using the RestTemplate.
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.
ThreadChannelConnectionFactory	A very simple connection factory that caches a channel per thread.
WebFluxNodeLocator	A LocalizedQueueConnectionFactory.NodeLocator using the Spring WebFlux WebClient.

Enum Summary

Enum	Description
AbstractConnectionFactory.AddressShuffleMode	The mode used to shuffle the addresses.
CachingConnectionFactory.CacheMode	The cache mode.
CachingConnectionFactory.ConfirmType	The type of publisher confirms to use.

Exception Summary

Exception	Description
AfterCompletionFailedException	Represents a failure to commit or rollback when performing afterCompletion after the primary transaction completes.
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.