Package org.springframework.amqp.rabbit.connection

Class PooledChannelConnectionFactory

java.lang.Object

org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory

All Implemented Interfaces:

com.rabbitmq.client.ShutdownListener, java.util.EventListener, ConnectionFactory, Aware, BeanNameAware, DisposableBean, ApplicationContextAware, ApplicationEventPublisherAware, ApplicationListener<ContextClosedEvent>

public class PooledChannelConnectionFactory
extends AbstractConnectionFactory
implements com.rabbitmq.client.ShutdownListener

A very simple connection factory that caches channels using Apache Pool2 GenericObjectPools (one for transactional and one for non-transactional channels). The pools have default configuration but they can be configured using a callback.

Since:

2.3

Author:

Gary Russell, Leonardo Ferreira

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

AbstractConnectionFactory.AddressShuffleMode

Field Summary

Fields inherited from class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

DEFAULT_CLOSE_TIMEOUT, logger

Constructor Summary

Constructors

Constructor	Description
PooledChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)	Construct an instance.

Method Summary

Modifier and Type	Method	Description
void	addConnectionListener(ConnectionListener listener)
Connection	createConnection()
void	destroy()
boolean	isSimplePublisherConfirms()	Return true if simple publisher confirms are enabled.
void	resetConnection()	Close the connection(s).
void	setPoolConfigurer(java.util.function.BiConsumer<org.apache.commons.pool2.impl.GenericObjectPool<com.rabbitmq.client.Channel>,java.lang.Boolean> poolConfigurer)	Add a consumer to configure the object pool.
void	setPublisherConnectionFactory(AbstractConnectionFactory publisherConnectionFactory)	Set a custom publisher connection factory; the type does not need to be the same as this factory.
void	setSimplePublisherConfirms(boolean simplePublisherConfirms)	Enable simple publisher confirms.

Methods inherited from class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

addChannelListener, clearConnectionListeners, createBareConnection, doSetPublisherConnectionFactory, getApplicationContext, getApplicationEventPublisher, getBeanName, getChannelListener, getCloseTimeout, getConnectionListener, getConnectionNameStrategy, getContextStopped, getDefaultHostName, getExecutorService, getHost, getPort, getPublisherConnectionFactory, getRabbitConnectionFactory, getUsername, getVirtualHost, hasPublisherConnectionFactory, onApplicationEvent, removeConnectionListener, setAddresses, setAddressResolver, setAddressShuffleMode, setApplicationContext, setApplicationEventPublisher, setBeanName, setChannelListeners, setCloseExceptionLogger, setCloseTimeout, setConnectionListeners, setConnectionNameStrategy, setConnectionThreadFactory, setConnectionTimeout, setExecutor, setHost, setPassword, setPort, setRecoveryListener, setRequestedHeartBeat, setShuffleAddresses, setUri, setUri, setUsername, setVirtualHost, shutdownCompleted, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.amqp.rabbit.connection.ConnectionFactory

isPublisherConfirms, isPublisherReturns

Methods inherited from interface com.rabbitmq.client.ShutdownListener

shutdownCompleted

Constructor Detail

PooledChannelConnectionFactory

public PooledChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)

Construct an instance.

Parameters:

rabbitConnectionFactory - the rabbitmq connection factory.

Method Detail

setPublisherConnectionFactory

public void setPublisherConnectionFactory(@Nullable
                                          AbstractConnectionFactory publisherConnectionFactory)

Description copied from class: AbstractConnectionFactory

Set a custom publisher connection factory; the type does not need to be the same as this factory.

Overrides:

setPublisherConnectionFactory in class AbstractConnectionFactory

Parameters:

publisherConnectionFactory - the factory.

setPoolConfigurer

public void setPoolConfigurer(java.util.function.BiConsumer<org.apache.commons.pool2.impl.GenericObjectPool<com.rabbitmq.client.Channel>,java.lang.Boolean> poolConfigurer)

Add a consumer to configure the object pool. The second argument is true when called with the transactional pool.

Parameters:

poolConfigurer - the configurer.

isSimplePublisherConfirms

public boolean isSimplePublisherConfirms()

Description copied from interface: ConnectionFactory

Return true if simple publisher confirms are enabled.

Specified by:

isSimplePublisherConfirms in interface ConnectionFactory

Returns:

simplePublisherConfirms

setSimplePublisherConfirms

public void setSimplePublisherConfirms(boolean simplePublisherConfirms)

Enable simple publisher confirms.

Parameters:

simplePublisherConfirms - true to enable.

addConnectionListener

public void addConnectionListener(ConnectionListener listener)

Specified by:

addConnectionListener in interface ConnectionFactory

Overrides:

addConnectionListener in class AbstractConnectionFactory

createConnection

public Connection createConnection()
                            throws AmqpException

Specified by:

createConnection in interface ConnectionFactory

Throws:

AmqpException

resetConnection

public void resetConnection()

Close the connection(s). This will impact any in-process operations. New connection(s) will be created on demand after this method returns. This might be used to force a reconnect to the primary broker after failing over to a secondary broker.

Specified by:

resetConnection in interface ConnectionFactory

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean

Overrides:

destroy in class AbstractConnectionFactory