Class ThreadChannelConnectionFactory

java.lang.Object
org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
All Implemented Interfaces:
com.rabbitmq.client.ShutdownListener, EventListener, ConnectionFactory, Aware, BeanNameAware, DisposableBean, ApplicationContextAware, ApplicationEventPublisherAware, ApplicationListener<ContextClosedEvent>, Lifecycle, Phased, SmartLifecycle

public class ThreadChannelConnectionFactory extends AbstractConnectionFactory implements com.rabbitmq.client.ShutdownListener, SmartLifecycle
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, Leonardo Ferreira
  • Constructor Details

    • ThreadChannelConnectionFactory

      public ThreadChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
      Construct an instance.
      Parameters:
      rabbitConnectionFactory - the rabbitmq connection factory.
  • Method Details