|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.http.nio.pool.AbstractNIOConnPool<T,C,E>
T
- routeC
- connection objectE
- pool entry@Contract(threading=SAFE_CONDITIONAL) public abstract class AbstractNIOConnPool<T,C,E extends PoolEntry<T,C>>
Abstract non-blocking connection pool.
Constructor Summary | |
---|---|
AbstractNIOConnPool(ConnectingIOReactor ioReactor,
NIOConnFactory<T,C> connFactory,
int defaultMaxPerRoute,
int maxTotal)
Deprecated. use AbstractNIOConnPool(ConnectingIOReactor,
NIOConnFactory, SocketAddressResolver, int, int) |
|
AbstractNIOConnPool(ConnectingIOReactor ioReactor,
NIOConnFactory<T,C> connFactory,
SocketAddressResolver<T> addressResolver,
int defaultMaxPerRoute,
int maxTotal)
|
Method Summary | |
---|---|
void |
closeExpired()
|
void |
closeIdle(long idletime,
TimeUnit timeUnit)
|
protected abstract E |
createEntry(T route,
C conn)
|
protected void |
enumAvailable(PoolEntryCallback<T,C> callback)
Enumerates all available connections. |
protected void |
enumEntries(Iterator<E> it,
PoolEntryCallback<T,C> callback)
Deprecated. (4.3.2) |
protected void |
enumLeased(PoolEntryCallback<T,C> callback)
Enumerates all leased connections. |
int |
getDefaultMaxPerRoute()
|
int |
getMaxPerRoute(T route)
|
int |
getMaxTotal()
|
Set<T> |
getRoutes()
Returns snapshot of all knows routes |
PoolStats |
getStats(T route)
|
PoolStats |
getTotalStats()
|
boolean |
isShutdown()
|
Future<E> |
lease(T route,
Object state)
|
Future<E> |
lease(T route,
Object state,
FutureCallback<E> callback)
|
Future<E> |
lease(T route,
Object state,
long connectTimeout,
long leaseTimeout,
TimeUnit timeUnit,
FutureCallback<E> callback)
|
Future<E> |
lease(T route,
Object state,
long connectTimeout,
TimeUnit timeUnit,
FutureCallback<E> callback)
|
protected void |
onLease(E entry)
|
protected void |
onRelease(E entry)
|
protected void |
onReuse(E entry)
|
void |
release(E entry,
boolean reusable)
|
protected void |
requestCancelled(SessionRequest request)
|
protected void |
requestCompleted(SessionRequest request)
|
protected void |
requestFailed(SessionRequest request)
|
protected void |
requestTimeout(SessionRequest request)
|
protected SocketAddress |
resolveLocalAddress(T route)
Deprecated. (4.3) use SocketAddressResolver |
protected SocketAddress |
resolveRemoteAddress(T route)
Deprecated. (4.3) use SocketAddressResolver |
void |
setDefaultMaxPerRoute(int max)
|
void |
setMaxPerRoute(T route,
int max)
|
void |
setMaxTotal(int max)
|
void |
shutdown(long waitMs)
|
String |
toString()
|
void |
validatePendingRequests()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
@Deprecated public AbstractNIOConnPool(ConnectingIOReactor ioReactor, NIOConnFactory<T,C> connFactory, int defaultMaxPerRoute, int maxTotal)
AbstractNIOConnPool(ConnectingIOReactor,
NIOConnFactory, SocketAddressResolver, int, int)
public AbstractNIOConnPool(ConnectingIOReactor ioReactor, NIOConnFactory<T,C> connFactory, SocketAddressResolver<T> addressResolver, int defaultMaxPerRoute, int maxTotal)
Method Detail |
---|
@Deprecated protected SocketAddress resolveRemoteAddress(T route)
SocketAddressResolver
@Deprecated protected SocketAddress resolveLocalAddress(T route)
SocketAddressResolver
protected abstract E createEntry(T route, C conn)
protected void onLease(E entry)
protected void onRelease(E entry)
protected void onReuse(E entry)
public boolean isShutdown()
public void shutdown(long waitMs) throws IOException
IOException
public Future<E> lease(T route, Object state, long connectTimeout, TimeUnit timeUnit, FutureCallback<E> callback)
public Future<E> lease(T route, Object state, long connectTimeout, long leaseTimeout, TimeUnit timeUnit, FutureCallback<E> callback)
public Future<E> lease(T route, Object state, FutureCallback<E> callback)
lease
in interface ConnPool<T,E extends PoolEntry<T,C>>
public Future<E> lease(T route, Object state)
public void release(E entry, boolean reusable)
release
in interface ConnPool<T,E extends PoolEntry<T,C>>
public void validatePendingRequests()
protected void requestCompleted(SessionRequest request)
protected void requestCancelled(SessionRequest request)
protected void requestFailed(SessionRequest request)
protected void requestTimeout(SessionRequest request)
public void setMaxTotal(int max)
setMaxTotal
in interface ConnPoolControl<T>
public int getMaxTotal()
getMaxTotal
in interface ConnPoolControl<T>
public void setDefaultMaxPerRoute(int max)
setDefaultMaxPerRoute
in interface ConnPoolControl<T>
public int getDefaultMaxPerRoute()
getDefaultMaxPerRoute
in interface ConnPoolControl<T>
public void setMaxPerRoute(T route, int max)
setMaxPerRoute
in interface ConnPoolControl<T>
public int getMaxPerRoute(T route)
getMaxPerRoute
in interface ConnPoolControl<T>
public PoolStats getTotalStats()
getTotalStats
in interface ConnPoolControl<T>
public PoolStats getStats(T route)
getStats
in interface ConnPoolControl<T>
public Set<T> getRoutes()
protected void enumAvailable(PoolEntryCallback<T,C> callback)
protected void enumLeased(PoolEntryCallback<T,C> callback)
@Deprecated protected void enumEntries(Iterator<E> it, PoolEntryCallback<T,C> callback)
enumLeased(org.apache.http.pool.PoolEntryCallback)
or enumAvailable(org.apache.http.pool.PoolEntryCallback)
instead.
public void closeIdle(long idletime, TimeUnit timeUnit)
public void closeExpired()
public String toString()
toString
in class Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |