public class PooledChannelConnectionFactory extends AbstractConnectionFactory implements com.rabbitmq.client.ShutdownListener
GenericObjectPools (one for transactional and one for non-transactional
channels). The pools have default configuration but they can be configured using
a callback.AbstractConnectionFactory.AddressShuffleModeDEFAULT_CLOSE_TIMEOUT, logger| Constructor and Description |
|---|
PooledChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
Construct an instance.
|
| Modifier and Type | Method and 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.
|
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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitisPublisherConfirms, isPublisherReturnspublic PooledChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
rabbitConnectionFactory - the rabbitmq connection factory.public void setPublisherConnectionFactory(@Nullable
AbstractConnectionFactory publisherConnectionFactory)
AbstractConnectionFactorysetPublisherConnectionFactory in class AbstractConnectionFactorypublisherConnectionFactory - the factory.public void setPoolConfigurer(java.util.function.BiConsumer<org.apache.commons.pool2.impl.GenericObjectPool<com.rabbitmq.client.Channel>,java.lang.Boolean> poolConfigurer)
poolConfigurer - the configurer.public boolean isSimplePublisherConfirms()
ConnectionFactoryisSimplePublisherConfirms in interface ConnectionFactorypublic void setSimplePublisherConfirms(boolean simplePublisherConfirms)
simplePublisherConfirms - true to enable.public void addConnectionListener(ConnectionListener listener)
addConnectionListener in interface ConnectionFactoryaddConnectionListener in class AbstractConnectionFactorypublic Connection createConnection() throws org.springframework.amqp.AmqpException
createConnection in interface ConnectionFactoryorg.springframework.amqp.AmqpExceptionpublic void resetConnection()
public void destroy()
destroy in interface org.springframework.beans.factory.DisposableBeandestroy in class AbstractConnectionFactory