org.springframework.amqp.rabbit.connection
Class AbstractConnectionFactory

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

All Implemented Interfaces:

ConnectionFactory, DisposableBean

Direct Known Subclasses:

CachingConnectionFactory

public abstract class AbstractConnectionFactory
extends Object
implements ConnectionFactory, DisposableBean

Author:

Dave Syer, Gary Russell

Field Summary

static int	DEFAULT_CLOSE_TIMEOUT
protected org.apache.commons.logging.Log	logger

Constructor Summary

AbstractConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
Create a new SingleConnectionFactory for the given target ConnectionFactory.

Method Summary

void	addChannelListener(ChannelListener listener)
void	addConnectionListener(ConnectionListener listener)
protected Connection	createBareConnection()
void	destroy()
protected ChannelListener	getChannelListener() A composite channel listener to be used by subclasses when creating and closing channels.
protected ConnectionListener	getConnectionListener() A composite connection listener to be used by subclasses when creating and closing connections.
protected String	getDefaultHostName()
String	getHost()
int	getPort()
String	getVirtualHost()
void	setAddresses(String addresses) Set addresses for clustering.
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	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)
void	setRequestedHeartBeat(int requestedHeartBeat)
void	setUsername(String username)
void	setVirtualHost(String virtualHost)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

createConnection

Field Detail

logger

protected final org.apache.commons.logging.Log logger

DEFAULT_CLOSE_TIMEOUT

public static final int DEFAULT_CLOSE_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

AbstractConnectionFactory

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

Create a new SingleConnectionFactory for the given target ConnectionFactory.

Parameters:

rabbitConnectionFactory - the target ConnectionFactory

Method Detail

setUsername

public void setUsername(String username)

setPassword

public void setPassword(String password)

setHost

public void setHost(String host)

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)

getPort

public int getPort()

Specified by:

getPort in interface ConnectionFactory

setAddresses

public void setAddresses(String addresses)

Set addresses for clustering.

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

setChannelListeners

public void setChannelListeners(List<? extends ChannelListener> listeners)

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.

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.

createBareConnection

protected final Connection createBareConnection()

getDefaultHostName

protected final String getDefaultHostName()

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean