@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.IOReactorExceptionpublic PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor)
throws org.apache.http.nio.reactor.IOReactorException
org.apache.http.nio.reactor.IOReactorExceptionprotected void finalize()
throws java.lang.Throwable
finalize in class java.lang.Objectjava.lang.Throwableprotected ClientAsyncConnectionFactory createClientAsyncConnectionFactory()
public AsyncSchemeRegistry getSchemeRegistry()
getSchemeRegistry in interface ClientAsyncConnectionManagerpublic void execute(org.apache.http.nio.reactor.IOEventDispatch eventDispatch)
throws java.io.IOException
execute in interface org.apache.http.nio.reactor.IOReactorjava.io.IOExceptionpublic org.apache.http.nio.reactor.IOReactorStatus getStatus()
getStatus in interface org.apache.http.nio.reactor.IOReactorpublic void shutdown(long waitMs)
throws java.io.IOException
shutdown in interface org.apache.http.nio.reactor.IOReactorjava.io.IOExceptionpublic void shutdown()
throws java.io.IOException
shutdown in interface org.apache.http.nio.reactor.IOReactorjava.io.IOExceptionprivate 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 ClientAsyncConnectionManagerpublic void releaseConnection(ManagedClientAsyncConnection conn, long keepalive, java.util.concurrent.TimeUnit tunit)
releaseConnection in interface ClientAsyncConnectionManagerpublic 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()