@Deprecated public class PoolingClientAsyncConnectionManager extends java.lang.Object implements ClientAsyncConnectionManager, org.apache.http.pool.ConnPoolControl<org.apache.http.conn.routing.HttpRoute>
Modifier and Type | Class and Description |
---|---|
(package private) class |
PoolingClientAsyncConnectionManager.InternalPoolEntryCallback
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
private ClientAsyncConnectionFactory |
connFactory
Deprecated.
|
private org.apache.http.nio.reactor.ConnectingIOReactor |
ioreactor
Deprecated.
|
private org.apache.commons.logging.Log |
log
Deprecated.
|
private HttpNIOConnPool |
pool
Deprecated.
|
private AsyncSchemeRegistry |
schemeRegistry
Deprecated.
|
Constructor and Description |
---|
PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor)
Deprecated.
|
PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor,
AsyncSchemeRegistry schemeRegistry)
Deprecated.
|
PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor,
AsyncSchemeRegistry schemeRegistry,
long timeToLive,
java.util.concurrent.TimeUnit tunit)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
closeExpiredConnections()
Deprecated.
|
void |
closeIdleConnections(long idleTimeout,
java.util.concurrent.TimeUnit tunit)
Deprecated.
|
protected ClientAsyncConnectionFactory |
createClientAsyncConnectionFactory()
Deprecated.
|
void |
execute(org.apache.http.nio.reactor.IOEventDispatch eventDispatch)
Deprecated.
|
protected void |
finalize()
Deprecated.
|
private java.lang.String |
format(HttpPoolEntry entry)
Deprecated.
|
private java.lang.String |
format(org.apache.http.conn.routing.HttpRoute route,
java.lang.Object state)
Deprecated.
|
private java.lang.String |
formatStats(org.apache.http.conn.routing.HttpRoute route)
Deprecated.
|
int |
getDefaultMaxPerRoute()
Deprecated.
|
int |
getMaxPerRoute(org.apache.http.conn.routing.HttpRoute route)
Deprecated.
|
int |
getMaxTotal()
Deprecated.
|
AsyncSchemeRegistry |
getSchemeRegistry()
Deprecated.
|
org.apache.http.pool.PoolStats |
getStats(org.apache.http.conn.routing.HttpRoute route)
Deprecated.
|
org.apache.http.nio.reactor.IOReactorStatus |
getStatus()
Deprecated.
|
org.apache.http.pool.PoolStats |
getTotalStats()
Deprecated.
|
java.util.concurrent.Future<ManagedClientAsyncConnection> |
leaseConnection(org.apache.http.conn.routing.HttpRoute route,
java.lang.Object state,
long connectTimeout,
java.util.concurrent.TimeUnit tunit,
org.apache.http.concurrent.FutureCallback<ManagedClientAsyncConnection> callback)
Deprecated.
|
void |
releaseConnection(ManagedClientAsyncConnection conn,
long keepalive,
java.util.concurrent.TimeUnit tunit)
Deprecated.
|
void |
setDefaultMaxPerRoute(int max)
Deprecated.
|
void |
setMaxPerRoute(org.apache.http.conn.routing.HttpRoute route,
int max)
Deprecated.
|
void |
setMaxTotal(int max)
Deprecated.
|
void |
shutdown()
Deprecated.
|
void |
shutdown(long waitMs)
Deprecated.
|
private final org.apache.commons.logging.Log log
private final org.apache.http.nio.reactor.ConnectingIOReactor ioreactor
private final HttpNIOConnPool pool
private final AsyncSchemeRegistry schemeRegistry
private final ClientAsyncConnectionFactory connFactory
public PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor, AsyncSchemeRegistry schemeRegistry, long timeToLive, java.util.concurrent.TimeUnit tunit)
public PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor, AsyncSchemeRegistry schemeRegistry) throws org.apache.http.nio.reactor.IOReactorException
org.apache.http.nio.reactor.IOReactorException
public PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor) throws org.apache.http.nio.reactor.IOReactorException
org.apache.http.nio.reactor.IOReactorException
protected void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable
protected ClientAsyncConnectionFactory createClientAsyncConnectionFactory()
public AsyncSchemeRegistry getSchemeRegistry()
getSchemeRegistry
in interface ClientAsyncConnectionManager
public void execute(org.apache.http.nio.reactor.IOEventDispatch eventDispatch) throws java.io.IOException
execute
in interface org.apache.http.nio.reactor.IOReactor
java.io.IOException
public org.apache.http.nio.reactor.IOReactorStatus getStatus()
getStatus
in interface org.apache.http.nio.reactor.IOReactor
public void shutdown(long waitMs) throws java.io.IOException
shutdown
in interface org.apache.http.nio.reactor.IOReactor
java.io.IOException
public void shutdown() throws java.io.IOException
shutdown
in interface org.apache.http.nio.reactor.IOReactor
java.io.IOException
private java.lang.String format(org.apache.http.conn.routing.HttpRoute route, java.lang.Object state)
private java.lang.String formatStats(org.apache.http.conn.routing.HttpRoute route)
private java.lang.String format(HttpPoolEntry entry)
public java.util.concurrent.Future<ManagedClientAsyncConnection> leaseConnection(org.apache.http.conn.routing.HttpRoute route, java.lang.Object state, long connectTimeout, java.util.concurrent.TimeUnit tunit, org.apache.http.concurrent.FutureCallback<ManagedClientAsyncConnection> callback)
leaseConnection
in interface ClientAsyncConnectionManager
public void releaseConnection(ManagedClientAsyncConnection conn, long keepalive, java.util.concurrent.TimeUnit tunit)
releaseConnection
in interface ClientAsyncConnectionManager
public org.apache.http.pool.PoolStats getTotalStats()
getTotalStats
in interface org.apache.http.pool.ConnPoolControl<org.apache.http.conn.routing.HttpRoute>
public org.apache.http.pool.PoolStats getStats(org.apache.http.conn.routing.HttpRoute route)
getStats
in interface org.apache.http.pool.ConnPoolControl<org.apache.http.conn.routing.HttpRoute>
public void setMaxTotal(int max)
setMaxTotal
in interface org.apache.http.pool.ConnPoolControl<org.apache.http.conn.routing.HttpRoute>
public void setDefaultMaxPerRoute(int max)
setDefaultMaxPerRoute
in interface org.apache.http.pool.ConnPoolControl<org.apache.http.conn.routing.HttpRoute>
public void setMaxPerRoute(org.apache.http.conn.routing.HttpRoute route, int max)
setMaxPerRoute
in interface org.apache.http.pool.ConnPoolControl<org.apache.http.conn.routing.HttpRoute>
public int getMaxTotal()
getMaxTotal
in interface org.apache.http.pool.ConnPoolControl<org.apache.http.conn.routing.HttpRoute>
public int getDefaultMaxPerRoute()
getDefaultMaxPerRoute
in interface org.apache.http.pool.ConnPoolControl<org.apache.http.conn.routing.HttpRoute>
public int getMaxPerRoute(org.apache.http.conn.routing.HttpRoute route)
getMaxPerRoute
in interface org.apache.http.pool.ConnPoolControl<org.apache.http.conn.routing.HttpRoute>
public void closeIdleConnections(long idleTimeout, java.util.concurrent.TimeUnit tunit)
public void closeExpiredConnections()