public class PooledChannelConnectionFactory extends AbstractConnectionFactory
GenericObjectPools (one for transactional and one for non-transactional
channels). The pools have default configuration but they can be configured using
a callback.DEFAULT_CLOSE_TIMEOUT, logger| Constructor and Description |
|---|
PooledChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
Construct an instance.
|
| Modifier and Type | Method and Description |
|---|---|
Connection |
createConnection() |
void |
destroy() |
boolean |
isSimplePublisherConfirms()
Return true if simple publisher confirms are enabled.
|
void |
setPoolConfigurer(BiConsumer<org.apache.commons.pool2.impl.GenericObjectPool<com.rabbitmq.client.Channel>,Boolean> poolConfigurer)
Add a consumer to configure the object pool.
|
void |
setSimplePublisherConfirms(boolean simplePublisherConfirms)
Enable simple publisher confirms.
|
addChannelListener, addConnectionListener, clearConnectionListeners, createBareConnection, getApplicationContext, getApplicationEventPublisher, getBeanName, getChannelListener, getCloseTimeout, getConnectionListener, getContextStopped, getDefaultHostName, getExecutorService, getHost, getPort, getPublisherConnectionFactory, getRabbitConnectionFactory, getUsername, getVirtualHost, hasPublisherConnectionFactory, onApplicationEvent, removeConnectionListener, setAddresses, setAddressResolver, setApplicationContext, setApplicationEventPublisher, setBeanName, setChannelListeners, setCloseTimeout, setConnectionListeners, setConnectionNameStrategy, setConnectionThreadFactory, setConnectionTimeout, setExecutor, setHost, setPassword, setPort, setPublisherConnectionFactory, setRecoveryListener, setRequestedHeartBeat, setShuffleAddresses, setUri, setUri, setUsername, setVirtualHost, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitisPublisherConfirms, isPublisherReturnspublic PooledChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
rabbitConnectionFactory - the rabbitmq connection factory.public void setPoolConfigurer(BiConsumer<org.apache.commons.pool2.impl.GenericObjectPool<com.rabbitmq.client.Channel>,Boolean> poolConfigurer)
poolConfigurer - the configurer.public boolean isSimplePublisherConfirms()
ConnectionFactorypublic void setSimplePublisherConfirms(boolean simplePublisherConfirms)
simplePublisherConfirms - true to enable.public Connection createConnection() throws AmqpException
AmqpExceptionpublic void destroy()
destroy in interface DisposableBeandestroy in class AbstractConnectionFactory