AbstractConnectionFactory (Spring AMQP 2.2.12.RELEASE API)

java.lang.Object
- org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

All Implemented Interfaces:

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

Direct Known Subclasses:

CachingConnectionFactory
```
public abstract class AbstractConnectionFactory
extends Object
implements ConnectionFactory, DisposableBean, BeanNameAware, ApplicationContextAware, ApplicationEventPublisherAware, ApplicationListener<ContextClosedEvent>
```
Author:

Dave Syer, Gary Russell, Steve Powell, Artem Bilan, Will Droste

Field Summary

Fields
Modifier and Type Field and Description

static int DEFAULT_CLOSE_TIMEOUT

protected Log logger

Fields
Modifier and Type	Field and Description
`static int`	`DEFAULT_CLOSE_TIMEOUT`
`protected Log`	`logger`

Constructor Summary

Constructors
Constructor and Description
`AbstractConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)` Create a new AbstractConnectionFactory for the given target ConnectionFactory, with no publisher connection factory.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addChannelListener(ChannelListener listener)`
`void`	`addConnectionListener(ConnectionListener listener)`
`void`	`clearConnectionListeners()`
`protected Connection`	`createBareConnection()`
`void`	`destroy()`
`protected ApplicationContext`	`getApplicationContext()`
`protected ApplicationEventPublisher`	`getApplicationEventPublisher()`
`protected String`	`getBeanName()` Return a bean name of the component or null if not a bean.
`protected ChannelListener`	`getChannelListener()` A composite channel listener to be used by subclasses when creating and closing channels.
`int`	`getCloseTimeout()`
`protected ConnectionListener`	`getConnectionListener()` A composite connection listener to be used by subclasses when creating and closing connections.
`protected boolean`	`getContextStopped()`
`protected String`	`getDefaultHostName()`
`protected ExecutorService`	`getExecutorService()`
`String`	`getHost()`
`int`	`getPort()`
`ConnectionFactory`	`getPublisherConnectionFactory()` Return a separate connection factory for publishers (if implemented).
`com.rabbitmq.client.ConnectionFactory`	`getRabbitConnectionFactory()` Return a reference to the underlying Rabbit Connection factory.
`String`	`getUsername()` Return the user name from the underlying rabbit connection factory.
`String`	`getVirtualHost()`
`boolean`	`hasPublisherConnectionFactory()`
`void`	`onApplicationEvent(ContextClosedEvent event)`
`boolean`	`removeConnectionListener(ConnectionListener listener)`
`void`	`setAddresses(String addresses)` Set addresses for clustering.
`void`	`setAddressResolver(com.rabbitmq.client.AddressResolver addressResolver)` Set an `AddressResolver` to use when creating connections; overrides `setAddresses(String)`, `setHost(String)`, and `setPort(int)`.
`void`	`setApplicationContext(ApplicationContext applicationContext)`
`void`	`setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)`
`void`	`setBeanName(String name)`
`void`	`setChannelListeners(List<? extends ChannelListener> listeners)`
`void`	`setCloseTimeout(int closeTimeout)` How long to wait (milliseconds) for a response to a connection close operation from the broker; default 30000 (30 seconds).
`void`	`setConnectionListeners(List<? extends ConnectionListener> listeners)`
`void`	`setConnectionNameStrategy(ConnectionNameStrategy connectionNameStrategy)` Provide a `ConnectionNameStrategy` to build the name for the target RabbitMQ connection.
`void`	`setConnectionThreadFactory(ThreadFactory threadFactory)` Set the `ThreadFactory` on the underlying rabbit connection factory.
`void`	`setConnectionTimeout(int connectionTimeout)`
`void`	`setExecutor(Executor executor)` Provide an Executor for use by the Rabbit ConnectionFactory when creating connections.
`void`	`setHost(String host)`
`void`	`setPassword(String password)`
`void`	`setPort(int port)`
`protected void`	`setPublisherConnectionFactory(AbstractConnectionFactory publisherConnectionFactory)`
`void`	`setRecoveryListener(com.rabbitmq.client.RecoveryListener recoveryListener)` Set a `RecoveryListener` that will be added to each connection created.
`void`	`setRequestedHeartBeat(int requestedHeartBeat)`
`void`	`setShuffleAddresses(boolean shuffleAddresses)` When `addresses` are provided and there is more than one, set to true to shuffle the list before opening a new connection so that the connection to the broker will be attempted in random order.
`void`	`setUri(String uri)`
`void`	`setUri(URI uri)`
`void`	`setUsername(String username)`
`void`	`setVirtualHost(String virtualHost)`
`String`	`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
createConnection, isPublisherConfirms, isPublisherReturns, isSimplePublisherConfirms

- Field Detail
  - DEFAULT_CLOSE_TIMEOUT
```
public static final int DEFAULT_CLOSE_TIMEOUT
```
    See Also:
    
    Constant Field Values
  - logger
```
protected final Log logger
```
- Constructor Detail
  - AbstractConnectionFactory
```
public AbstractConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
```
    Create a new AbstractConnectionFactory for the given target ConnectionFactory, with no publisher connection factory.
    
    Parameters:
    
    rabbitConnectionFactory - the target ConnectionFactory
- Method Detail
  - setPublisherConnectionFactory
```
protected final void setPublisherConnectionFactory(AbstractConnectionFactory publisherConnectionFactory)
```
  - setApplicationContext
```
public void setApplicationContext(ApplicationContext applicationContext)
```
    Specified by:
    
    setApplicationContext in interface ApplicationContextAware
  - getApplicationContext
```
protected ApplicationContext getApplicationContext()
```
  - setApplicationEventPublisher
```
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
```
    Specified by:
    
    setApplicationEventPublisher in interface ApplicationEventPublisherAware
  - getApplicationEventPublisher
```
protected ApplicationEventPublisher getApplicationEventPublisher()
```
  - onApplicationEvent
```
public void onApplicationEvent(ContextClosedEvent event)
```
    Specified by:
    
    onApplicationEvent in interface ApplicationListener<ContextClosedEvent>
  - getContextStopped
```
protected boolean getContextStopped()
```
  - getRabbitConnectionFactory
```
public com.rabbitmq.client.ConnectionFactory getRabbitConnectionFactory()
```
    Return a reference to the underlying Rabbit Connection factory.
    
    Returns:
    
    the connection factory.
    
    Since:
    
    1.5.6
  - getUsername
```
public String getUsername()
```
    Return the user name from the underlying rabbit connection factory.
    
    Specified by:
    
    getUsername in interface ConnectionFactory
    
    Returns:
    
    the user name.
    
    Since:
    
    1.6
  - setUsername
```
public void setUsername(String username)
```
  - setPassword
```
public void setPassword(String password)
```
  - setHost
```
public void setHost(String host)
```
  - setConnectionThreadFactory
```
public void setConnectionThreadFactory(ThreadFactory threadFactory)
```
    Set the ThreadFactory on the underlying rabbit connection factory.
    
    Parameters:
    
    threadFactory - the thread factory.
    
    Since:
    
    1.5.3
  - setAddressResolver
```
public void setAddressResolver(com.rabbitmq.client.AddressResolver addressResolver)
```
    Set an AddressResolver to use when creating connections; overrides setAddresses(String), setHost(String), and setPort(int).
    
    Parameters:
    
    addressResolver - the resolver.
    
    Since:
    
    2.1.15
  - setUri
```
public void setUri(URI uri)
```
    Parameters:
    
    uri - the URI
    
    Since:
    
    1.5
    
    See Also:
    
    ConnectionFactory.setUri(URI)
  - setUri
```
public void setUri(String uri)
```
    Parameters:
    
    uri - the URI
    
    Since:
    
    1.5
    
    See Also:
    
    ConnectionFactory.setUri(String)
  - getHost
```
public String getHost()
```
    Specified by:
    
    getHost in interface ConnectionFactory
  - setVirtualHost
```
public void setVirtualHost(String virtualHost)
```
  - getVirtualHost
```
public String getVirtualHost()
```
    Specified by:
    
    getVirtualHost in interface ConnectionFactory
  - setPort
```
public void setPort(int port)
```
  - setRequestedHeartBeat
```
public void setRequestedHeartBeat(int requestedHeartBeat)
```
  - setConnectionTimeout
```
public void setConnectionTimeout(int connectionTimeout)
```
  - getPort
```
public int getPort()
```
    Specified by:
    
    getPort in interface ConnectionFactory
  - setAddresses
```
public void setAddresses(String addresses)
```
    Set addresses for clustering. This property overrides the host+port properties if not empty.
    
    Parameters:
    
    addresses - list of addresses with form "host[:port],..."
  - getConnectionListener
```
protected ConnectionListener getConnectionListener()
```
    A composite connection listener to be used by subclasses when creating and closing connections.
    
    Returns:
    
    the connection listener
  - getChannelListener
```
protected ChannelListener getChannelListener()
```
    A composite channel listener to be used by subclasses when creating and closing channels.
    
    Returns:
    
    the channel listener
  - setConnectionListeners
```
public void setConnectionListeners(List<? extends ConnectionListener> listeners)
```
  - addConnectionListener
```
public void addConnectionListener(ConnectionListener listener)
```
    Specified by:
    
    addConnectionListener in interface ConnectionFactory
  - removeConnectionListener
```
public boolean removeConnectionListener(ConnectionListener listener)
```
    Specified by:
    
    removeConnectionListener in interface ConnectionFactory
  - clearConnectionListeners
```
public void clearConnectionListeners()
```
    Specified by:
    
    clearConnectionListeners in interface ConnectionFactory
  - setChannelListeners
```
public void setChannelListeners(List<? extends ChannelListener> listeners)
```
  - setRecoveryListener
```
public void setRecoveryListener(com.rabbitmq.client.RecoveryListener recoveryListener)
```
    Set a RecoveryListener that will be added to each connection created.
    
    Parameters:
    
    recoveryListener - the listener.
    
    Since:
    
    2.0
  - addChannelListener
```
public void addChannelListener(ChannelListener listener)
```
  - setExecutor
```
public void setExecutor(Executor executor)
```
    Provide an Executor for use by the Rabbit ConnectionFactory when creating connections. Can either be an ExecutorService or a Spring ThreadPoolTaskExecutor, as defined by a <task:executor/> element.
    
    Parameters:
    
    executor - The executor.
  - getExecutorService
```
@Nullable
protected ExecutorService getExecutorService()
```
  - setCloseTimeout
```
public void setCloseTimeout(int closeTimeout)
```
    How long to wait (milliseconds) for a response to a connection close operation from the broker; default 30000 (30 seconds).
    
    Parameters:
    
    closeTimeout - the closeTimeout to set.
  - getCloseTimeout
```
public int getCloseTimeout()
```
  - setConnectionNameStrategy
```
public void setConnectionNameStrategy(ConnectionNameStrategy connectionNameStrategy)
```
    Provide a ConnectionNameStrategy to build the name for the target RabbitMQ connection. The beanName together with a counter is used by default.
    
    Parameters:
    
    connectionNameStrategy - the ConnectionNameStrategy to use.
    
    Since:
    
    2.0
  - setBeanName
```
public void setBeanName(String name)
```
    Specified by:
    
    setBeanName in interface BeanNameAware
  - getBeanName
```
@Nullable
protected String getBeanName()
```
    Return a bean name of the component or null if not a bean.
    
    Returns:
    
    the bean name or null.
    
    Since:
    
    1.7.9
  - setShuffleAddresses
```
public void setShuffleAddresses(boolean shuffleAddresses)
```
    When addresses are provided and there is more than one, set to true to shuffle the list before opening a new connection so that the connection to the broker will be attempted in random order.
    
    Parameters:
    
    shuffleAddresses - true to shuffle the list.
    
    Since:
    
    2.1.8
    
    See Also:
    
    Collections.shuffle(List)
  - hasPublisherConnectionFactory
```
public boolean hasPublisherConnectionFactory()
```
  - getPublisherConnectionFactory
```
public ConnectionFactory getPublisherConnectionFactory()
```
    Description copied from interface: ConnectionFactory
    
    Return a separate connection factory for publishers (if implemented).
    
    Specified by:
    
    getPublisherConnectionFactory in interface ConnectionFactory
    
    Returns:
    
    the publisher connection factory, or null.
  - createBareConnection
```
protected final Connection createBareConnection()
```
  - getDefaultHostName
```
protected final String getDefaultHostName()
```
  - destroy
```
public void destroy()
```
    Specified by:
    
    destroy in interface DisposableBean
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object

Class AbstractConnectionFactory

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.springframework.amqp.rabbit.connection.ConnectionFactory

Field Detail

DEFAULT_CLOSE_TIMEOUT

logger

Constructor Detail

AbstractConnectionFactory

Method Detail

setPublisherConnectionFactory

setApplicationContext

getApplicationContext

setApplicationEventPublisher

getApplicationEventPublisher

onApplicationEvent

getContextStopped

getRabbitConnectionFactory

getUsername

setUsername

setPassword

setHost

setConnectionThreadFactory

setAddressResolver

setUri

setUri

getHost

setVirtualHost

getVirtualHost

setPort

setRequestedHeartBeat

setConnectionTimeout

getPort

setAddresses

getConnectionListener

getChannelListener

setConnectionListeners

addConnectionListener

removeConnectionListener

clearConnectionListeners

setChannelListeners

setRecoveryListener

addChannelListener

setExecutor

getExecutorService

setCloseTimeout

getCloseTimeout

setConnectionNameStrategy

setBeanName

getBeanName

setShuffleAddresses

hasPublisherConnectionFactory

getPublisherConnectionFactory

createBareConnection

getDefaultHostName

destroy

toString