public class ThreadChannelConnectionFactory extends AbstractConnectionFactory
closeThreadChannel().DEFAULT_CLOSE_TIMEOUT, logger| Constructor and Description |
|---|
ThreadChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
Construct an instance.
|
| Modifier and Type | Method and Description |
|---|---|
void |
closeThreadChannel()
Close the channel associated with this thread, if any.
|
Connection |
createConnection() |
void |
destroy() |
boolean |
isSimplePublisherConfirms()
Return true if simple publisher confirms are enabled.
|
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 ThreadChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
rabbitConnectionFactory - the rabbitmq connection factory.public boolean isSimplePublisherConfirms()
ConnectionFactorypublic void setSimplePublisherConfirms(boolean simplePublisherConfirms)
simplePublisherConfirms - true to enable.public Connection createConnection() throws AmqpException
AmqpExceptionpublic void closeThreadChannel()
public void destroy()
destroy in interface DisposableBeandestroy in class AbstractConnectionFactory