@Deprecated public class PoolingClientAsyncConnectionManager extends Object implements ClientAsyncConnectionManager, ConnPoolControl<HttpRoute>
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,
TimeUnit tunit)
Deprecated.
|
public PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor, AsyncSchemeRegistry schemeRegistry, long timeToLive, TimeUnit tunit)
public PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor, AsyncSchemeRegistry schemeRegistry) throws org.apache.http.nio.reactor.IOReactorException
public PoolingClientAsyncConnectionManager(org.apache.http.nio.reactor.ConnectingIOReactor ioreactor) throws org.apache.http.nio.reactor.IOReactorException
protected void finalize() throws Throwable
protected ClientAsyncConnectionFactory createClientAsyncConnectionFactory()
public AsyncSchemeRegistry getSchemeRegistry()
getSchemeRegistry
in interface ClientAsyncConnectionManager
public void execute(org.apache.http.nio.reactor.IOEventDispatch eventDispatch) throws IOException
execute
in interface org.apache.http.nio.reactor.IOReactor
IOException
public org.apache.http.nio.reactor.IOReactorStatus getStatus()
getStatus
in interface org.apache.http.nio.reactor.IOReactor
public void shutdown(long waitMs) throws IOException
shutdown
in interface org.apache.http.nio.reactor.IOReactor
IOException
public void shutdown() throws IOException
shutdown
in interface org.apache.http.nio.reactor.IOReactor
IOException
public Future<ManagedClientAsyncConnection> leaseConnection(HttpRoute route, Object state, long connectTimeout, TimeUnit tunit, FutureCallback<ManagedClientAsyncConnection> callback)
leaseConnection
in interface ClientAsyncConnectionManager
public void releaseConnection(ManagedClientAsyncConnection conn, long keepalive, TimeUnit tunit)
releaseConnection
in interface ClientAsyncConnectionManager
public PoolStats getTotalStats()
getTotalStats
in interface ConnPoolControl<HttpRoute>
public PoolStats getStats(HttpRoute route)
getStats
in interface ConnPoolControl<HttpRoute>
public void setMaxTotal(int max)
setMaxTotal
in interface ConnPoolControl<HttpRoute>
public void setDefaultMaxPerRoute(int max)
setDefaultMaxPerRoute
in interface ConnPoolControl<HttpRoute>
public void setMaxPerRoute(HttpRoute route, int max)
setMaxPerRoute
in interface ConnPoolControl<HttpRoute>
public int getMaxTotal()
getMaxTotal
in interface ConnPoolControl<HttpRoute>
public int getDefaultMaxPerRoute()
getDefaultMaxPerRoute
in interface ConnPoolControl<HttpRoute>
public int getMaxPerRoute(HttpRoute route)
getMaxPerRoute
in interface ConnPoolControl<HttpRoute>
public void closeIdleConnections(long idleTimeout, TimeUnit tunit)
public void closeExpiredConnections()
Copyright © 2010–2021 The Apache Software Foundation. All rights reserved.