Package org.apache.http.impl.nio.pool
Class BasicNIOConnPool
- java.lang.Object
-
- org.apache.http.nio.pool.AbstractNIOConnPool<HttpHost,NHttpClientConnection,BasicNIOPoolEntry>
-
- org.apache.http.impl.nio.pool.BasicNIOConnPool
-
- All Implemented Interfaces:
ConnPool<HttpHost,BasicNIOPoolEntry>
,ConnPoolControl<HttpHost>
@Contract(threading=SAFE) public class BasicNIOConnPool extends AbstractNIOConnPool<HttpHost,NHttpClientConnection,BasicNIOPoolEntry>
A very basicConnPool
implementation that represents a pool of non-blockingNHttpClientConnection
connections identified by anHttpHost
instance. Please note this pool implementation does not support complex routes via a proxy cannot differentiate between direct and proxied connections.- Since:
- 4.2
- See Also:
HttpHost
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
BasicNIOConnPool.BasicAddressResolver
-
Field Summary
Fields Modifier and Type Field Description private int
connectTimeout
private static java.util.concurrent.atomic.AtomicLong
COUNTER
-
Constructor Summary
Constructors Constructor Description BasicNIOConnPool(ConnectingIOReactor ioReactor)
BasicNIOConnPool(ConnectingIOReactor ioReactor, int connectTimeout, ConnectionConfig config)
BasicNIOConnPool(ConnectingIOReactor ioReactor, ConnectionConfig config)
BasicNIOConnPool(ConnectingIOReactor ioReactor, NIOConnFactory<HttpHost,NHttpClientConnection> connFactory, int connectTimeout)
BasicNIOConnPool(ConnectingIOReactor ioReactor, NIOConnFactory<HttpHost,NHttpClientConnection> connFactory, HttpParams params)
Deprecated.BasicNIOConnPool(ConnectingIOReactor ioReactor, HttpParams params)
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description protected BasicNIOPoolEntry
createEntry(HttpHost host, NHttpClientConnection conn)
java.util.concurrent.Future<BasicNIOPoolEntry>
lease(HttpHost route, java.lang.Object state)
java.util.concurrent.Future<BasicNIOPoolEntry>
lease(HttpHost route, java.lang.Object state, FutureCallback<BasicNIOPoolEntry> callback)
Attempts to lease a connection for the given route and with the given state from the pool.protected void
onLease(BasicNIOPoolEntry entry)
protected void
onRelease(BasicNIOPoolEntry entry)
protected java.net.SocketAddress
resolveLocalAddress(HttpHost host)
Deprecated.(4.3) useSocketAddressResolver
protected java.net.SocketAddress
resolveRemoteAddress(HttpHost host)
Deprecated.(4.3) useSocketAddressResolver
-
Methods inherited from class org.apache.http.nio.pool.AbstractNIOConnPool
closeExpired, closeIdle, enumAvailable, enumEntries, enumLeased, getDefaultMaxPerRoute, getMaxPerRoute, getMaxTotal, getRoutes, getStats, getTotalStats, isShutdown, lease, lease, onReuse, release, requestCancelled, requestCompleted, requestFailed, requestTimeout, setDefaultMaxPerRoute, setMaxPerRoute, setMaxTotal, shutdown, toString, validatePendingRequests
-
-
-
-
Constructor Detail
-
BasicNIOConnPool
@Deprecated public BasicNIOConnPool(ConnectingIOReactor ioReactor, NIOConnFactory<HttpHost,NHttpClientConnection> connFactory, HttpParams params)
Deprecated.
-
BasicNIOConnPool
@Deprecated public BasicNIOConnPool(ConnectingIOReactor ioReactor, HttpParams params)
Deprecated.
-
BasicNIOConnPool
public BasicNIOConnPool(ConnectingIOReactor ioReactor, NIOConnFactory<HttpHost,NHttpClientConnection> connFactory, int connectTimeout)
- Since:
- 4.3
-
BasicNIOConnPool
public BasicNIOConnPool(ConnectingIOReactor ioReactor, int connectTimeout, ConnectionConfig config)
- Since:
- 4.3
-
BasicNIOConnPool
public BasicNIOConnPool(ConnectingIOReactor ioReactor, ConnectionConfig config)
- Since:
- 4.3
-
BasicNIOConnPool
public BasicNIOConnPool(ConnectingIOReactor ioReactor)
- Since:
- 4.3
-
-
Method Detail
-
resolveRemoteAddress
@Deprecated protected java.net.SocketAddress resolveRemoteAddress(HttpHost host)
Deprecated.(4.3) useSocketAddressResolver
- Overrides:
resolveRemoteAddress
in classAbstractNIOConnPool<HttpHost,NHttpClientConnection,BasicNIOPoolEntry>
-
resolveLocalAddress
@Deprecated protected java.net.SocketAddress resolveLocalAddress(HttpHost host)
Deprecated.(4.3) useSocketAddressResolver
- Overrides:
resolveLocalAddress
in classAbstractNIOConnPool<HttpHost,NHttpClientConnection,BasicNIOPoolEntry>
-
createEntry
protected BasicNIOPoolEntry createEntry(HttpHost host, NHttpClientConnection conn)
- Specified by:
createEntry
in classAbstractNIOConnPool<HttpHost,NHttpClientConnection,BasicNIOPoolEntry>
-
lease
public java.util.concurrent.Future<BasicNIOPoolEntry> lease(HttpHost route, java.lang.Object state, FutureCallback<BasicNIOPoolEntry> callback)
Description copied from interface:ConnPool
Attempts to lease a connection for the given route and with the given state from the pool.- Specified by:
lease
in interfaceConnPool<HttpHost,BasicNIOPoolEntry>
- Overrides:
lease
in classAbstractNIOConnPool<HttpHost,NHttpClientConnection,BasicNIOPoolEntry>
- Parameters:
route
- route of the connection.state
- arbitrary object that represents a particular state (usually a security principal or a unique token identifying the user whose credentials have been used while establishing the connection). May benull
.callback
- operation completion callback.- Returns:
- future for a leased pool entry.
-
lease
public java.util.concurrent.Future<BasicNIOPoolEntry> lease(HttpHost route, java.lang.Object state)
- Overrides:
lease
in classAbstractNIOConnPool<HttpHost,NHttpClientConnection,BasicNIOPoolEntry>
-
onLease
protected void onLease(BasicNIOPoolEntry entry)
- Overrides:
onLease
in classAbstractNIOConnPool<HttpHost,NHttpClientConnection,BasicNIOPoolEntry>
-
onRelease
protected void onRelease(BasicNIOPoolEntry entry)
- Overrides:
onRelease
in classAbstractNIOConnPool<HttpHost,NHttpClientConnection,BasicNIOPoolEntry>
-
-