AbstractConnectionFactory (Spring AMQP 2.1.0.M1 API)

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

All Implemented Interfaces:

java.util.EventListener, ConnectionFactory, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextClosedEvent>

Direct Known Subclasses:

CachingConnectionFactory
```
public abstract class AbstractConnectionFactory
extends java.lang.Object
implements ConnectionFactory, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.BeanNameAware, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, org.springframework.context.ApplicationListener<org.springframework.context.event.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 org.apache.commons.logging.Log logger

Fields
Modifier and Type	Field and Description
`static int`	`DEFAULT_CLOSE_TIMEOUT`
`protected org.apache.commons.logging.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 org.springframework.context.ApplicationContext`	`getApplicationContext()`
`protected org.springframework.context.ApplicationEventPublisher`	`getApplicationEventPublisher()`
`protected java.lang.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 java.lang.String`	`getDefaultHostName()`
`protected java.util.concurrent.ExecutorService`	`getExecutorService()`
`java.lang.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.
`java.lang.String`	`getUsername()` Return the user name from the underlying rabbit connection factory.
`java.lang.String`	`getVirtualHost()`
`boolean`	`hasPublisherConnectionFactory()`
`void`	`onApplicationEvent(org.springframework.context.event.ContextClosedEvent event)`
`boolean`	`removeConnectionListener(ConnectionListener listener)`
`void`	`setAddresses(java.lang.String addresses)` Set addresses for clustering.
`void`	`setApplicationContext(org.springframework.context.ApplicationContext applicationContext)`
`void`	`setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)`
`void`	`setBeanName(java.lang.String name)`
`void`	`setChannelListeners(java.util.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(java.util.List<? extends ConnectionListener> listeners)`
`void`	`setConnectionNameStrategy(ConnectionNameStrategy connectionNameStrategy)` Provide a `ConnectionNameStrategy` to build the name for the target RabbitMQ connection.
`void`	`setConnectionThreadFactory(java.util.concurrent.ThreadFactory threadFactory)` Set the `ThreadFactory` on the underlying rabbit connection factory.
`void`	`setConnectionTimeout(int connectionTimeout)`
`void`	`setExecutor(java.util.concurrent.Executor executor)` Provide an Executor for use by the Rabbit ConnectionFactory when creating connections.
`void`	`setHost(java.lang.String host)`
`void`	`setPassword(java.lang.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`	`setUri(java.lang.String uri)`
`void`	`setUri(java.net.URI uri)`
`void`	`setUsername(java.lang.String username)`
`void`	`setVirtualHost(java.lang.String virtualHost)`
`java.lang.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 org.apache.commons.logging.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(org.springframework.context.ApplicationContext applicationContext)
```
    Specified by:
    
    setApplicationContext in interface org.springframework.context.ApplicationContextAware
  - getApplicationContext
```
protected org.springframework.context.ApplicationContext getApplicationContext()
```
  - setApplicationEventPublisher
```
public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
```
    Specified by:
    
    setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAware
  - getApplicationEventPublisher
```
protected org.springframework.context.ApplicationEventPublisher getApplicationEventPublisher()
```
  - onApplicationEvent
```
public void onApplicationEvent(org.springframework.context.event.ContextClosedEvent event)
```
    Specified by:
    
    onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.event.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 java.lang.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(java.lang.String username)
```
  - setPassword
```
public void setPassword(java.lang.String password)
```
  - setHost
```
public void setHost(java.lang.String host)
```
  - setConnectionThreadFactory
```
public void setConnectionThreadFactory(java.util.concurrent.ThreadFactory threadFactory)
```
    Set the ThreadFactory on the underlying rabbit connection factory.
    
    Parameters:
    
    threadFactory - the thread factory.
    
    Since:
    
    1.5.3
  - setUri
```
public void setUri(java.net.URI uri)
```
    Parameters:
    
    uri - the URI
    
    Since:
    
    1.5
    
    See Also:
    
    ConnectionFactory.setUri(URI)
  - setUri
```
public void setUri(java.lang.String uri)
```
    Parameters:
    
    uri - the URI
    
    Since:
    
    1.5
    
    See Also:
    
    ConnectionFactory.setUri(String)
  - getHost
```
public java.lang.String getHost()
```
    Specified by:
    
    getHost in interface ConnectionFactory
  - setVirtualHost
```
public void setVirtualHost(java.lang.String virtualHost)
```
  - getVirtualHost
```
public java.lang.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(java.lang.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(java.util.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(java.util.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(java.util.concurrent.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
```
protected java.util.concurrent.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(java.lang.String name)
```
    Specified by:
    
    setBeanName in interface org.springframework.beans.factory.BeanNameAware
  - getBeanName
```
protected java.lang.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
  - 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 java.lang.String getDefaultHostName()
```
  - destroy
```
public void destroy()
```
    Specified by:
    
    destroy in interface org.springframework.beans.factory.DisposableBean
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.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

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

hasPublisherConnectionFactory

getPublisherConnectionFactory

createBareConnection

getDefaultHostName

destroy

toString