Package com.predic8.membrane.core.transport.http

Class ConnectionManager

java.lang.Object

com.predic8.membrane.core.transport.http.ConnectionManager

public class ConnectionManager
extends Object

Pools TCP/IP connections, holding them open for a configurable number of milliseconds.

With keep-alive use as follows: Connection connection = connectionManager.getConnection(...); try { ... } finally { connection.release(); }

Without keep-alive replace Connection.release() by Connection.close().

Note that you should call Connection.release() exactly once, or alternatively Connection.close() at least once.

Constructor Summary

Constructors

Constructor	Description
ConnectionManager(long keepAliveTimeout, TimerManager timerManager)

Method Summary

Modifier and Type	Method	Description
Connection	getConnection(String host, int port, String localHost, SSLProvider sslProvider, int connectTimeout)
Connection	getConnection(String host, int port, String localHost, SSLProvider sslProvider, int connectTimeout, String sniServerName, ProxyConfiguration proxy, SSLContext proxySSLContext, String[] applicationProtocols)
int	getNumberInPool()
void	releaseConnection(Connection connection)
void	shutdownWhenDone()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectionManager

public ConnectionManager(long keepAliveTimeout,
 @Nullable
 TimerManager timerManager)

Parameters:

keepAliveTimeout - milliseconds to keep idle connections around for

timerManager - a TimerManager instance to use to close idle connections. Providing a TimerManager instance prevents the ConnectionManager from creating its own Timer (and TimerManager). Can be null.

Method Details

getConnection

public Connection getConnection(String host,
 int port,
 String localHost,
 SSLProvider sslProvider,
 int connectTimeout,
 @Nullable
 String sniServerName,
 @Nullable
 ProxyConfiguration proxy,
 @Nullable
 SSLContext proxySSLContext,
 @Nullable
 String[] applicationProtocols)
                         throws UnknownHostException,
IOException

Throws:

UnknownHostException

IOException

getConnection

public Connection getConnection(String host,
 int port,
 String localHost,
 SSLProvider sslProvider,
 int connectTimeout)
                         throws UnknownHostException,
IOException

Throws:

UnknownHostException

IOException

releaseConnection

public void releaseConnection(Connection connection)

shutdownWhenDone

public void shutdownWhenDone()

getNumberInPool

public int getNumberInPool()

toString

public String toString()

Overrides:

toString in class Object