|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.amqp.rabbit.connection.AbstractConnectionFactory
public abstract class AbstractConnectionFactory
| 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 java.lang.String |
getDefaultHostName()
|
java.lang.String |
getHost()
|
int |
getPort()
|
java.lang.String |
getVirtualHost()
|
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 |
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)
|
| 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 |
|---|
protected final org.apache.commons.logging.Log logger
public static final int DEFAULT_CLOSE_TIMEOUT
| Constructor Detail |
|---|
public AbstractConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
rabbitConnectionFactory - the target ConnectionFactory| Method Detail |
|---|
public 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 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 void setChannelListeners(java.util.List<? extends ChannelListener> listeners)
public void addChannelListener(ChannelListener listener)
public void setExecutor(java.util.concurrent.Executor executor)
executor - The executor.public void setCloseTimeout(int closeTimeout)
closeTimeout - the closeTimeout to set.protected final Connection createBareConnection()
protected final java.lang.String getDefaultHostName()
public void destroy()
destroy in interface org.springframework.beans.factory.DisposableBean
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||