Package org.springframework.amqp.rabbit.connection
@NonNullApi
package org.springframework.amqp.rabbit.connection
Provides classes related to connections.
-
ClassDescriptionThe mode used to shuffle the addresses.Default implementation of
ConditionalExceptionLogger
for logging channel close exceptions.AbstractConnectionFactory
implementation that routesAbstractRoutingConnectionFactory.createConnection()
calls to one of various target ConnectionFactories based on a lookup key.Represents a failure to commit or rollback when performing afterCompletion after the primary transaction completes.An exception thrown if the connection is an auto recover connection that is not currently open and is in the process of being recovered.AConnectionFactory
implementation that (when the cache mode isCachingConnectionFactory.CacheMode.CHANNEL
(default) returns the same Connection from allCachingConnectionFactory.createConnection()
calls, and ignores calls toConnection.close()
and cachesChannel
.The cache mode.The type of publisher confirms to use.A listener for new channel creation and destruction.Subinterface ofChannel
to be implemented by Channel proxies.ARecoveryListener
that closes the recovered channel, to avoid orphaned consumers.A composite listener that invokes its delegages in turn.TheAmqpEvent
emitted by theCachingConnectionFactory
when its connections are blocked.An interface based ConnectionFactory for creatingConnections
.Utility methods for configuring connection factories.Helper class to handleConnectionFactory
context binding and unbinding when executing instructions.Helper class for managing a Spring based RabbitConnectionFactory
, in particular for obtaining transactional Rabbit resources for a given ConnectionFactory.Callback interface for resource creation.A listener for connection creation and closing.A strategy to build an application-specific connection name, which can be displayed in the management UI if RabbitMQ server supports it.Subinterface ofConnection
to be implemented by Connection proxies.TheAmqpEvent
emitted by theCachingConnectionFactory
when its connections are unblocked.Consumers register their primary channels with this class.Base class for correlating publisher confirms to sent messages.Represents a publisher confirmation.Callback to determine the connection factory using the provided information.ARoutingConnectionFactory
that determines the node on which a queue is located and returns a factory that connects directly to that node.NodeLocator<T>Used to obtain a connection factory for the queue leader.Instances of this object track pending publisher confirms.A very simple connection factory that caches channels using Apache Pool2GenericObjectPool
s (one for transactional and one for non-transactional channels).Instances of this interface support a single listener being registered for publisher confirms with multiple channels, by adding context to the callbacks.Listeners implementing this interface can participate in publisher confirms received from multiple channels, by invoking addListener on each channel.A factory forPublisherCallbackChannel
s.Channel wrapper to allow a single listener able to handle confirms from multiple channels.Factory bean to create a RabbitMQ ConnectionFactory, delegating most setter methods and optionally enabling SSL, with or without certificate validation.Rabbit resource holder, wrapping a RabbitMQ Connection and Channel.ANodeLocator
using theRestTemplate
.Implementations select a connection factory based on a supplied key.Functional sub interface enabling a lambda for the onShutDown method.Simply a Connection.AConnectionNameStrategy
that returns the value of a (required) property.Central helper that manages resources per thread to be used by resource management code.AnAbstractRoutingConnectionFactory
implementation which gets alookupKey
for currentConnectionFactory
from thread-bound resource by key of the instance of thisConnectionFactory
.A very simple connection factory that caches a channel per thread.ANodeLocator
using the Spring WebFluxWebClient
.