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
ConditionalExceptionLoggerfor logging channel close exceptions.AbstractConnectionFactoryimplementation 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.AConnectionFactoryimplementation 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 ofChannelto be implemented by Channel proxies.ARecoveryListenerthat closes the recovered channel, to avoid orphaned consumers.A composite listener that invokes its delegates in turn.TheAmqpEventemitted by theCachingConnectionFactorywhen its connections are blocked.An interface based ConnectionFactory for creatingConnections.Utility methods for configuring connection factories.Helper class to handleConnectionFactorycontext 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 ofConnectionto be implemented by Connection proxies.TheAmqpEventemitted by theCachingConnectionFactorywhen 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.ARoutingConnectionFactorythat 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 Pool2GenericObjectPools (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 forPublisherCallbackChannels.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.ANodeLocatorusing theRestTemplate.Implementations select a connection factory based on a supplied key.Functional sub interface enabling a lambda for the onShutDown method.Simply a Connection.AConnectionNameStrategythat returns the value of a (required) property.Central helper that manages resources per thread to be used by resource management code.AnAbstractRoutingConnectionFactoryimplementation which gets alookupKeyfor currentConnectionFactoryfrom thread-bound resource by key of the instance of thisConnectionFactory.A very simple connection factory that caches a channel per thread.ANodeLocatorusing the Spring WebFluxWebClient.