org.apache.hc.client5.http.impl.io

Class DefaultManagedHttpClientConnection

java.lang.Object

org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection

org.apache.hc.client5.http.impl.io.DefaultManagedHttpClientConnection

All Implemented Interfaces:

Closeable, AutoCloseable, ManagedHttpClientConnection, org.apache.hc.core5.http.HttpConnection, org.apache.hc.core5.http.io.BHttpConnection, org.apache.hc.core5.http.io.HttpClientConnection, org.apache.hc.core5.io.GracefullyCloseable, org.apache.hc.core5.util.Identifiable

public class DefaultManagedHttpClientConnection
extends org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection
implements ManagedHttpClientConnection, org.apache.hc.core5.util.Identifiable

Default ManagedHttpClientConnection implementation.

Since:

4.3

Constructor Summary

Constructors

Constructor and Description
DefaultManagedHttpClientConnection(String id)
DefaultManagedHttpClientConnection(String id, CharsetDecoder chardecoder, CharsetEncoder charencoder, org.apache.hc.core5.http.config.H1Config h1Config, org.apache.hc.core5.http.ContentLengthStrategy incomingContentStrategy, org.apache.hc.core5.http.ContentLengthStrategy outgoingContentStrategy, org.apache.hc.core5.http.io.HttpMessageWriterFactory<org.apache.hc.core5.http.ClassicHttpRequest> requestWriterFactory, org.apache.hc.core5.http.io.HttpMessageParserFactory<org.apache.hc.core5.http.ClassicHttpResponse> responseParserFactory)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	awaitInput(int arg0)
void	bind(Socket socket) Binds this connection to the given socket.
void	bind(org.apache.hc.core5.http.impl.io.SocketHolder socketHolder)
void	close()
protected InputStream	createContentInputStream(long arg0, org.apache.hc.core5.http.io.SessionInputBuffer arg1, InputStream arg2)
protected OutputStream	createContentOutputStream(long arg0, org.apache.hc.core5.http.io.SessionOutputBuffer arg1, OutputStream arg2, org.apache.hc.core5.function.Supplier<List<? extends org.apache.hc.core5.http.Header>> arg3)
protected org.apache.hc.core5.http.impl.io.SocketHolder	ensureOpen()
String	getId()
Socket	getSocket() Returns the underlying socket.
protected org.apache.hc.core5.http.impl.io.SocketHolder	getSocketHolder()
SSLSession	getSSLSession() Obtains the SSL session of the underlying connection, if any.
protected void	incrementRequestCount()
protected void	incrementResponseCount()
protected void	onRequestSubmitted(org.apache.hc.core5.http.ClassicHttpRequest request)
protected void	onResponseReceived(org.apache.hc.core5.http.ClassicHttpResponse response)
void	setSocketTimeout(int timeout)
void	shutdown(org.apache.hc.core5.io.ShutdownType shutdownType)

Methods inherited from class org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection

isConsistent, receiveResponseEntity, receiveResponseHeader, sendRequestEntity, sendRequestHeader, terminateRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.hc.core5.http.io.HttpClientConnection

isConsistent, receiveResponseEntity, receiveResponseHeader, sendRequestEntity, sendRequestHeader, terminateRequest

Methods inherited from interface org.apache.hc.core5.http.io.BHttpConnection

flush, isDataAvailable, isStale

Methods inherited from interface org.apache.hc.core5.http.HttpConnection

getEndpointDetails, getLocalAddress, getProtocolVersion, getRemoteAddress, getSocketTimeout, isOpen

Constructor Detail

DefaultManagedHttpClientConnection

public DefaultManagedHttpClientConnection(String id,
                                  CharsetDecoder chardecoder,
                                  CharsetEncoder charencoder,
                                  org.apache.hc.core5.http.config.H1Config h1Config,
                                  org.apache.hc.core5.http.ContentLengthStrategy incomingContentStrategy,
                                  org.apache.hc.core5.http.ContentLengthStrategy outgoingContentStrategy,
                                  org.apache.hc.core5.http.io.HttpMessageWriterFactory<org.apache.hc.core5.http.ClassicHttpRequest> requestWriterFactory,
                                  org.apache.hc.core5.http.io.HttpMessageParserFactory<org.apache.hc.core5.http.ClassicHttpResponse> responseParserFactory)

DefaultManagedHttpClientConnection

public DefaultManagedHttpClientConnection(String id)

Method Detail

getId

public String getId()

Specified by:

getId in interface org.apache.hc.core5.util.Identifiable

bind

public void bind(org.apache.hc.core5.http.impl.io.SocketHolder socketHolder)
          throws IOException

Throws:

IOException

getSocket

public Socket getSocket()

Description copied from interface: ManagedHttpClientConnection

Returns the underlying socket.

Specified by:

getSocket in interface ManagedHttpClientConnection

getSSLSession

public SSLSession getSSLSession()

Description copied from interface: ManagedHttpClientConnection

Obtains the SSL session of the underlying connection, if any. If this connection is open, and the underlying socket is an SSLSocket, the SSL session of that socket is obtained. This is a potentially blocking operation.

Specified by:

getSSLSession in interface ManagedHttpClientConnection

Specified by:

getSSLSession in interface org.apache.hc.core5.http.HttpConnection

Overrides:

getSSLSession in class org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection

Returns:

the underlying SSL session if available, null otherwise

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hc.core5.http.HttpConnection

Overrides:

close in class org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection

Throws:

IOException

setSocketTimeout

public void setSocketTimeout(int timeout)

Specified by:

setSocketTimeout in interface org.apache.hc.core5.http.HttpConnection

Overrides:

setSocketTimeout in class org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection

shutdown

public void shutdown(org.apache.hc.core5.io.ShutdownType shutdownType)

Specified by:

shutdown in interface org.apache.hc.core5.io.GracefullyCloseable

Overrides:

shutdown in class org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection

bind

public void bind(Socket socket)
          throws IOException

Description copied from interface: ManagedHttpClientConnection

Binds this connection to the given socket. The connection is considered open if it is bound and the underlying socket is connection to a remote host.

Specified by:

bind in interface ManagedHttpClientConnection

Overrides:

bind in class org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection

Parameters:

socket - the socket to bind the connection to.

Throws:

IOException

onResponseReceived

protected void onResponseReceived(org.apache.hc.core5.http.ClassicHttpResponse response)

Overrides:

onResponseReceived in class org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection

onRequestSubmitted

protected void onRequestSubmitted(org.apache.hc.core5.http.ClassicHttpRequest request)

Overrides:

onRequestSubmitted in class org.apache.hc.core5.http.impl.io.DefaultBHttpClientConnection

ensureOpen

protected org.apache.hc.core5.http.impl.io.SocketHolder ensureOpen()
                                                            throws IOException

Throws:

IOException

getSocketHolder

protected org.apache.hc.core5.http.impl.io.SocketHolder getSocketHolder()

createContentOutputStream

protected OutputStream createContentOutputStream(long arg0,
                                     org.apache.hc.core5.http.io.SessionOutputBuffer arg1,
                                     OutputStream arg2,
                                     org.apache.hc.core5.function.Supplier<List<? extends org.apache.hc.core5.http.Header>> arg3)

createContentInputStream

protected InputStream createContentInputStream(long arg0,
                                   org.apache.hc.core5.http.io.SessionInputBuffer arg1,
                                   InputStream arg2)

awaitInput

protected boolean awaitInput(int arg0)
                      throws IOException

Throws:

IOException

incrementRequestCount

protected void incrementRequestCount()

incrementResponseCount

protected void incrementResponseCount()