org.springframework.amqp.rabbit.connection

Class ThreadChannelConnectionFactory

java.lang.Object

org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory

All Implemented Interfaces:

EventListener, ConnectionFactory, Aware, BeanNameAware, DisposableBean, ApplicationContextAware, ApplicationEventPublisherAware, ApplicationListener<ContextClosedEvent>

public class ThreadChannelConnectionFactory
extends AbstractConnectionFactory

A very simple connection factory that caches a channel per thread. Users are responsible for releasing the thread's channel by calling closeThreadChannel().

Since:

2.3

Author:

Gary Russell

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 and Description
ThreadChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory) Construct an instance.

Method Summary

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.

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

addChannelListener, addConnectionListener, clearConnectionListeners, createBareConnection, getApplicationContext, getApplicationEventPublisher, getBeanName, getChannelListener, getCloseTimeout, getConnectionListener, getContextStopped, getDefaultHostName, getExecutorService, getHost, getPort, getPublisherConnectionFactory, getRabbitConnectionFactory, getUsername, getVirtualHost, hasPublisherConnectionFactory, onApplicationEvent, removeConnectionListener, setAddresses, setAddressResolver, setAddressShuffleMode, setApplicationContext, setApplicationEventPublisher, setBeanName, setChannelListeners, setCloseTimeout, setConnectionListeners, setConnectionNameStrategy, setConnectionThreadFactory, setConnectionTimeout, setExecutor, setHost, setPassword, setPort, setPublisherConnectionFactory, setRecoveryListener, setRequestedHeartBeat, setShuffleAddresses, setUri, setUri, setUsername, setVirtualHost, 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 org.springframework.context.ApplicationListener

forPayload

Constructor Detail

ThreadChannelConnectionFactory

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

Construct an instance.

Parameters:

rabbitConnectionFactory - the rabbitmq connection factory.

Method Detail

isSimplePublisherConfirms

public boolean isSimplePublisherConfirms()

Description copied from interface: ConnectionFactory

Return true if simple publisher confirms are enabled.

Returns:

simplePublisherConfirms

setSimplePublisherConfirms

public void setSimplePublisherConfirms(boolean simplePublisherConfirms)

Enable simple publisher confirms.

Parameters:

simplePublisherConfirms - true to enable.

createConnection

public Connection createConnection()
                            throws AmqpException

Throws:

AmqpException

closeThreadChannel

public void closeThreadChannel()

Close the channel associated with this thread, if any.

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean

Overrides:

destroy in class AbstractConnectionFactory