Provides classes related to connections.
Interface Summary Interface Description ChannelListenerA listener for new channel creation and destruction. ChannelProxySubinterface of
Channelto be implemented by Channel proxies.
Connection ConnectionFactoryAn interface based ConnectionFactory for creating
ConnectionFactoryUtils.ResourceFactoryCallback interface for resource creation. ConnectionListenerA listener for connection creation and closing. ConnectionNameStrategyA strategy to build an application-specific connection name, which can be displayed in the management UI if RabbitMQ server supports it. ConnectionProxySubinterface of
Connectionto be implemented by Connection proxies.
PublisherCallbackChannelInstances of this interface support a single listener being registered for publisher confirms with multiple channels, by adding context to the callbacks. PublisherCallbackChannel.ListenerListeners implementing this interface can participate in publisher confirms received from multiple channels, by invoking addListener on each channel. PublisherCallbackChannelFactoryA factory for
RoutingConnectionFactoryImplementations select a connection factory based on a supplied key. ShutDownChannelListenerFunctional sub interface enabling a lambda for the onShutDown method.
Class Summary Class Description AbstractConnectionFactory AbstractRoutingConnectionFactoryAbstract
ConnectionFactoryimplementation that routes
AbstractRoutingConnectionFactory.createConnection()calls to one of various target ConnectionFactories based on a lookup key.
RecoveryListenerthat closes the recovered channel, to avoid orphaned consumers.
CompositeChannelListener CompositeConnectionListenerA composite listener that invokes its delegages in turn. ConnectionBlockedEventThe
AmqpEventemitted by the
CachingConnectionFactorywhen its connections are blocked.
ConnectionFactoryConfigurationUtilsUtility methods for configuring connection factories. ConnectionFactoryContextWrapperHelper class to handle
ConnectionFactorycontext binding and unbinding when executing instructions.
ConnectionFactoryUtilsHelper class for managing a Spring based Rabbit
ConnectionFactory, in particular for obtaining transactional Rabbit resources for a given ConnectionFactory.
AmqpEventemitted by the
CachingConnectionFactorywhen its connections are unblocked.
ConsumerChannelRegistryConsumers register their primary channels with this class. CorrelationDataBase class for correlating publisher confirms to sent messages. CorrelationData.ConfirmRepresents a publisher confirmation. LocalizedQueueConnectionFactoryA
RoutingConnectionFactorythat determines the node on which a queue is located and returns a factory that connects directly to that node.
PendingConfirmInstances of this object track pending publisher confirms. PooledChannelConnectionFactoryA very simple connection factory that caches channels using Apache Pool2
GenericObjectPools (one for transactional and one for non-transactional channels).
PublisherCallbackChannelImplChannel wrapper to allow a single listener able to handle confirms from multiple channels. RabbitAccessor RabbitConnectionFactoryBeanFactory bean to create a RabbitMQ ConnectionFactory, delegating most setter methods and optionally enabling SSL, with or without certificate validation. RabbitResourceHolderRabbit resource holder, wrapping a RabbitMQ Connection and Channel. RabbitUtils SimpleConnectionSimply a Connection. SimplePropertyValueConnectionNameStrategyA
ConnectionNameStrategythat returns the value of a (required) property.
SimpleResourceHolderCentral helper that manages resources per thread to be used by resource management code. SimpleRoutingConnectionFactory ThreadChannelConnectionFactoryA very simple connection factory that caches a channel per thread.
Enum Summary Enum Description AbstractConnectionFactory.AddressShuffleModeThe mode used to shuffle the addresses. CachingConnectionFactory.CacheModeThe cache mode. CachingConnectionFactory.ConfirmTypeThe type of publisher confirms to use.
Exception Summary Exception Description AfterCompletionFailedExceptionRepresents a failure to commit or rollback when performing afterCompletion after the primary transaction completes. AutoRecoverConnectionNotCurrentlyOpenExceptionAn exception thrown if the connection is an auto recover connection that is not currently open and is in the process of being recovered.