Top Description Inners Fields Constructors Methods
org.apache.hc.core5.http.impl.bootstrap

public Class HttpRequester

extends Object
implements ConnPoolControl<HttpHost>, ModalCloseable
Class Inheritance
All Implemented Interfaces
org.apache.hc.core5.io.ModalCloseable, java.io.Closeable, java.lang.AutoCloseable, org.apache.hc.core5.pool.ConnPoolControl, org.apache.hc.core5.pool.ConnPoolStats
Imports
java.io.IOException, .InputStream, .InterruptedIOException, .OutputStream, java.net.InetSocketAddress, .Proxy, .Socket, java.security.AccessController, .PrivilegedActionException, .PrivilegedExceptionAction, java.util.Set, java.util.concurrent.ExecutionException, .Future, .TimeoutException, java.util.concurrent.atomic.AtomicReference, javax.net.ssl.SSLHandshakeException, .SSLParameters, .SSLSession, .SSLSocket, .SSLSocketFactory, org.apache.hc.core5.annotation.Internal, org.apache.hc.core5.function.Callback, .Resolver, org.apache.hc.core5.http.ClassicHttpRequest, .ClassicHttpResponse, .ConnectionClosedException, .ConnectionRequestTimeoutException, .HttpEntity, .HttpException, .HttpHost, .URIScheme, org.apache.hc.core5.http.config.CharCodingConfig, .Http1Config, org.apache.hc.core5.http.impl.DefaultAddressResolver, org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnectionFactory, .HttpRequestExecutor, org.apache.hc.core5.http.io.EofSensorInputStream, .EofSensorWatcher, .HttpClientConnection, .HttpClientResponseHandler, .HttpConnectionFactory, .HttpResponseInformationCallback, .SocketConfig, org.apache.hc.core5.http.io.entity.EntityUtils, .HttpEntityWrapper, org.apache.hc.core5.http.io.ssl.SSLSessionVerifier, org.apache.hc.core5.http.protocol.HttpContext, .HttpProcessor, org.apache.hc.core5.io.CloseMode, .Closer, .ModalCloseable, org.apache.hc.core5.net.URIAuthority, org.apache.hc.core5.pool.ConnPoolControl, .ManagedConnPool, .PoolEntry, .PoolStats, org.apache.hc.core5.util.Args, .Asserts, .TimeValue, .Timeout

HTTP/1.1 client side message exchange initiator.
Since
5.0

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class

Field Summary

Modifier and TypeField and Description
private final Resolver<HttpHost, InetSocketAddress>
private final HttpConnectionFactory<? extends HttpClientConnection>
private final ManagedConnPool<HttpHost, HttpClientConnection>
private final HttpProcessor
private final HttpRequestExecutor
private final SocketConfig
private final SSLSessionVerifier
private final Callback<SSLParameters>
private final SSLSocketFactory

Constructor Summary

AccessConstructor and Description
public
HttpRequester(final HttpRequestExecutor requestExecutor, final HttpProcessor httpProcessor, final ManagedConnPool<HttpHost, HttpClientConnection> connPool, final SocketConfig socketConfig, final HttpConnectionFactory<? extends HttpClientConnection> connectFactory, final SSLSocketFactory sslSocketFactory, final Callback<SSLParameters> sslSetupHandler, final SSLSessionVerifier sslSessionVerifier, final Resolver<HttpHost, InetSocketAddress> addressResolver)

Use RequesterBootstrap to create instances of this class.

Method Summary

Modifier and TypeMethod and Description
public void
close(final CloseMode
How to close the receiver.
closeMode
)

Implements org.apache.hc.core5.io.ModalCloseable.close.

Closes this process or endpoint and releases any system resources associated with it.
public void
close()

Implements java.io.Closeable.close.

Closes this stream and releases any system resources associated with it.
public void
public void
private Socket
createSocket(final HttpHost targetHost)

public ClassicHttpResponse
execute(final HttpClientConnection connection, final ClassicHttpRequest request, final HttpResponseInformationCallback informationCallback, final HttpContext context)

public ClassicHttpResponse
execute(final HttpClientConnection connection, final ClassicHttpRequest request, final HttpContext context)

public <T> T
execute(final HttpClientConnection connection, final ClassicHttpRequest request, final HttpContext context, final HttpClientResponseHandler<T> responseHandler)

public ClassicHttpResponse
execute(final HttpHost targetHost, final ClassicHttpRequest request, final HttpResponseInformationCallback informationCallback, final Timeout connectTimeout, final HttpContext context)

public ClassicHttpResponse
execute(final HttpHost targetHost, final ClassicHttpRequest request, final Timeout connectTimeout, final HttpContext context)

public <T> T
execute(final HttpHost targetHost, final ClassicHttpRequest request, final Timeout connectTimeout, final HttpContext context, final HttpClientResponseHandler<T> responseHandler)

public ConnPoolControl<HttpHost>
public int
public int
public int
public Set<HttpHost>
public PoolStats
public PoolStats
public boolean
keepAlive(final HttpClientConnection connection, final ClassicHttpRequest request, final ClassicHttpResponse response, final HttpContext context)

public void
public void
public void
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

addressResolverback to summary
private final Resolver<HttpHost, InetSocketAddress> addressResolver
connectFactoryback to summary
private final HttpConnectionFactory<? extends HttpClientConnection> connectFactory
connPoolback to summary
private final ManagedConnPool<HttpHost, HttpClientConnection> connPool
httpProcessorback to summary
private final HttpProcessor httpProcessor
requestExecutorback to summary
private final HttpRequestExecutor requestExecutor
socketConfigback to summary
private final SocketConfig socketConfig
sslSessionVerifierback to summary
private final SSLSessionVerifier sslSessionVerifier
sslSetupHandlerback to summary
private final Callback<SSLParameters> sslSetupHandler
sslSocketFactoryback to summary
private final SSLSocketFactory sslSocketFactory

Constructor Detail

HttpRequesterback to summary
public HttpRequester(final HttpRequestExecutor requestExecutor, final HttpProcessor httpProcessor, final ManagedConnPool<HttpHost, HttpClientConnection> connPool, final SocketConfig socketConfig, final HttpConnectionFactory<? extends HttpClientConnection> connectFactory, final SSLSocketFactory sslSocketFactory, final Callback<SSLParameters> sslSetupHandler, final SSLSessionVerifier sslSessionVerifier, final Resolver<HttpHost, InetSocketAddress> addressResolver)

Use RequesterBootstrap to create instances of this class.

Annotations
@Internal

Method Detail

closeback to summary
public void close(final CloseMode closeMode)

Implements org.apache.hc.core5.io.ModalCloseable.close.

Doc from org.apache.hc.core5.io.ModalCloseable.close.

Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect.

Parameters
closeMode:CloseMode

How to close the receiver.

Annotations
@Override
closeback to summary
public void close() throws IOException

Implements java.io.Closeable.close.

Doc from java.io.Closeable.close.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Annotations
@Override
Exceptions
IOException:
if an I/O error occurs
closeExpiredback to summary
public void closeExpired()

Implements org.apache.hc.core5.pool.ConnPoolControl.closeExpired.

Annotations
@Override
closeIdleback to summary
public void closeIdle(final TimeValue idleTime)

Implements org.apache.hc.core5.pool.ConnPoolControl.closeIdle.

Annotations
@Override
createSocketback to summary
private Socket createSocket(final HttpHost targetHost) throws IOException
executeback to summary
public ClassicHttpResponse execute(final HttpClientConnection connection, final ClassicHttpRequest request, final HttpResponseInformationCallback informationCallback, final HttpContext context) throws HttpException, IOException
executeback to summary
public ClassicHttpResponse execute(final HttpClientConnection connection, final ClassicHttpRequest request, final HttpContext context) throws HttpException, IOException
executeback to summary
public <T> T execute(final HttpClientConnection connection, final ClassicHttpRequest request, final HttpContext context, final HttpClientResponseHandler<T> responseHandler) throws HttpException, IOException
executeback to summary
public ClassicHttpResponse execute(final HttpHost targetHost, final ClassicHttpRequest request, final HttpResponseInformationCallback informationCallback, final Timeout connectTimeout, final HttpContext context) throws HttpException, IOException
executeback to summary
public ClassicHttpResponse execute(final HttpHost targetHost, final ClassicHttpRequest request, final Timeout connectTimeout, final HttpContext context) throws HttpException, IOException
executeback to summary
public <T> T execute(final HttpHost targetHost, final ClassicHttpRequest request, final Timeout connectTimeout, final HttpContext context, final HttpClientResponseHandler<T> responseHandler) throws HttpException, IOException
getConnPoolControlback to summary
public ConnPoolControl<HttpHost> getConnPoolControl()
getDefaultMaxPerRouteback to summary
public int getDefaultMaxPerRoute()

Implements org.apache.hc.core5.pool.ConnPoolControl.getDefaultMaxPerRoute.

Annotations
@Override
getMaxPerRouteback to summary
public int getMaxPerRoute(final HttpHost route)

Implements org.apache.hc.core5.pool.ConnPoolControl.getMaxPerRoute.

Annotations
@Override
getMaxTotalback to summary
public int getMaxTotal()

Implements org.apache.hc.core5.pool.ConnPoolControl.getMaxTotal.

Annotations
@Override
getRoutesback to summary
public Set<HttpHost> getRoutes()

Implements org.apache.hc.core5.pool.ConnPoolControl.getRoutes.

Annotations
@Override
getStatsback to summary
public PoolStats getStats(final HttpHost route)

Implements org.apache.hc.core5.pool.ConnPoolStats.getStats.

Annotations
@Override
getTotalStatsback to summary
public PoolStats getTotalStats()

Implements org.apache.hc.core5.pool.ConnPoolStats.getTotalStats.

Annotations
@Override
keepAliveback to summary
public boolean keepAlive(final HttpClientConnection connection, final ClassicHttpRequest request, final ClassicHttpResponse response, final HttpContext context) throws IOException
setDefaultMaxPerRouteback to summary
public void setDefaultMaxPerRoute(final int max)

Implements org.apache.hc.core5.pool.ConnPoolControl.setDefaultMaxPerRoute.

Annotations
@Override
setMaxPerRouteback to summary
public void setMaxPerRoute(final HttpHost route, final int max)

Implements org.apache.hc.core5.pool.ConnPoolControl.setMaxPerRoute.

Annotations
@Override
setMaxTotalback to summary
public void setMaxTotal(final int max)

Implements org.apache.hc.core5.pool.ConnPoolControl.setMaxTotal.

Annotations
@Override
org.apache.hc.core5.http.impl.bootstrap back to summary

private Class HttpRequester.PoolEntryHolder

extends Object
Class Inheritance
  • java.lang.Object
  • org.apache.hc.core5.http.impl.bootstrap.HttpRequester.PoolEntryHolder

Field Summary

Modifier and TypeField and Description
private final AtomicReference<PoolEntry<HttpHost, HttpClientConnection>>

Constructor Summary

AccessConstructor and Description
pack-priv

Method Summary

Modifier and TypeMethod and Description
pack-priv void
pack-priv HttpClientConnection
pack-priv void
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

poolEntryRefback to summary
private final AtomicReference<PoolEntry<HttpHost, HttpClientConnection>> poolEntryRef

Constructor Detail

PoolEntryHolderback to summary
pack-priv PoolEntryHolder(final PoolEntry<HttpHost, HttpClientConnection> poolEntry)

Method Detail

discardConnectionback to summary
pack-priv void discardConnection()
getConnectionback to summary
pack-priv HttpClientConnection getConnection()
releaseConnectionback to summary
pack-priv void releaseConnection()