public abstract class AbstractConnectionFactory extends java.lang.Object implements ConnectionFactory, org.springframework.beans.factory.DisposableBean
| Modifier and Type | Field and Description |
|---|---|
static int |
DEFAULT_CLOSE_TIMEOUT |
protected org.apache.commons.logging.Log |
logger |
| Constructor and Description |
|---|
AbstractConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
Create a new SingleConnectionFactory for the given target ConnectionFactory.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addChannelListener(ChannelListener listener) |
void |
addConnectionListener(ConnectionListener listener) |
void |
clearConnectionListeners() |
protected Connection |
createBareConnection() |
void |
destroy() |
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 java.lang.String |
getDefaultHostName() |
protected java.util.concurrent.ExecutorService |
getExecutorService() |
java.lang.String |
getHost() |
int |
getPort() |
java.lang.String |
getVirtualHost() |
boolean |
removeConnectionListener(ConnectionListener listener) |
void |
setAddresses(java.lang.String addresses)
Set addresses for clustering.
|
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 |
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) |
void |
setRequestedHeartBeat(int requestedHeartBeat) |
void |
setUsername(java.lang.String username) |
void |
setVirtualHost(java.lang.String virtualHost) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreateConnectionprotected final org.apache.commons.logging.Log logger
public static final int DEFAULT_CLOSE_TIMEOUT
public AbstractConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
rabbitConnectionFactory - the target ConnectionFactorypublic void setUsername(java.lang.String username)
public void setPassword(java.lang.String password)
public void setHost(java.lang.String host)
public java.lang.String getHost()
getHost in interface ConnectionFactorypublic void setVirtualHost(java.lang.String virtualHost)
public java.lang.String getVirtualHost()
getVirtualHost in interface ConnectionFactorypublic void setPort(int port)
public void setRequestedHeartBeat(int requestedHeartBeat)
public void setConnectionTimeout(int connectionTimeout)
public int getPort()
getPort in interface ConnectionFactorypublic void setAddresses(java.lang.String addresses)
addresses - list of addresses with form "host[:port],..."protected ConnectionListener getConnectionListener()
protected ChannelListener getChannelListener()
public void setConnectionListeners(java.util.List<? extends ConnectionListener> listeners)
public void addConnectionListener(ConnectionListener listener)
addConnectionListener in interface ConnectionFactorypublic boolean removeConnectionListener(ConnectionListener listener)
removeConnectionListener in interface ConnectionFactorypublic void clearConnectionListeners()
clearConnectionListeners in interface ConnectionFactorypublic void setChannelListeners(java.util.List<? extends ChannelListener> listeners)
public void addChannelListener(ChannelListener listener)
public void setExecutor(java.util.concurrent.Executor executor)
executor - The executor.protected java.util.concurrent.ExecutorService getExecutorService()
public void setCloseTimeout(int closeTimeout)
closeTimeout - the closeTimeout to set.public int getCloseTimeout()
protected final Connection createBareConnection()
protected final java.lang.String getDefaultHostName()
public void destroy()
destroy in interface org.springframework.beans.factory.DisposableBean