Package org.apache.hc.core5.testing.classic

Class LoggingBHttpClientConnection

java.lang.Object

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

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

org.apache.hc.core5.testing.classic.LoggingBHttpClientConnection

All Implemented Interfaces:

Closeable, AutoCloseable, HttpConnection, BHttpConnection, HttpClientConnection, SocketModalCloseable, ModalCloseable, Identifiable

public class LoggingBHttpClientConnection
extends DefaultBHttpClientConnection
implements Identifiable

Field Summary

Fields

Modifier and Type	Field	Description
private static final AtomicLong	COUNT
private final org.slf4j.Logger	headerLog
private final String	id
private final org.slf4j.Logger	log
private final Wire	wire

Constructor Summary

Constructors

Constructor	Description
LoggingBHttpClientConnection(Http1Config http1Config)
LoggingBHttpClientConnection(Http1Config http1Config, CharsetDecoder charDecoder, CharsetEncoder charEncoder, ContentLengthStrategy incomingContentStrategy, ContentLengthStrategy outgoingContentStrategy, HttpMessageWriterFactory<ClassicHttpRequest> requestWriterFactory, HttpMessageParserFactory<ClassicHttpResponse> responseParserFactory)

Method Summary

Modifier and Type	Method	Description
void	bind(Socket socket)	Binds this connection to the given Socket.
void	close()	Closes this connection gracefully.
void	close(CloseMode closeMode)	Closes this process or endpoint and releases any system resources associated with it.
String	getId()
protected void	onRequestSubmitted(ClassicHttpRequest request)
protected void	onResponseReceived(ClassicHttpResponse response)

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

isConsistent, receiveResponseEntity, receiveResponseHeader, sendRequestEntity, sendRequestHeader, terminateRequest

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

awaitInput, bind, createContentInputStream, createContentOutputStream, ensureOpen, flush, getEndpointDetails, getLocalAddress, getProtocolVersion, getRemoteAddress, getSocketHolder, getSocketTimeout, getSSLSession, incrementRequestCount, incrementResponseCount, isDataAvailable, isOpen, isStale, setSocketTimeout, toString

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.BHttpConnection

flush, isDataAvailable, isStale

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

getEndpointDetails, getLocalAddress, getProtocolVersion, getRemoteAddress, getSSLSession, isOpen

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

getSocketTimeout, setSocketTimeout

Field Details

COUNT

private static final AtomicLong COUNT

id

private final String id

log

private final org.slf4j.Logger log

headerLog

private final org.slf4j.Logger headerLog

wire

private final Wire wire

Constructor Details

LoggingBHttpClientConnection

public LoggingBHttpClientConnection(Http1Config http1Config,
 CharsetDecoder charDecoder,
 CharsetEncoder charEncoder,
 ContentLengthStrategy incomingContentStrategy,
 ContentLengthStrategy outgoingContentStrategy,
 HttpMessageWriterFactory<ClassicHttpRequest> requestWriterFactory,
 HttpMessageParserFactory<ClassicHttpResponse> responseParserFactory)

LoggingBHttpClientConnection

public LoggingBHttpClientConnection(Http1Config http1Config)

Method Details

getId

public String getId()

Specified by:

getId in interface Identifiable

close

public void close()
           throws IOException

Description copied from interface: HttpConnection

Closes this connection gracefully. This method will attempt to flush the internal output buffer prior to closing the underlying socket. This method MUST NOT be called from a different thread to force shutdown of the connection. Use shutdown instead.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface HttpConnection

Overrides:

close in class BHttpConnectionBase

Throws:

IOException

close

public void close(CloseMode closeMode)

Description copied from interface: ModalCloseable

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.

Specified by:

close in interface ModalCloseable

Overrides:

close in class BHttpConnectionBase

Parameters:

closeMode - How to close the receiver.

bind

public void bind(Socket socket)
          throws IOException

Description copied from class: BHttpConnectionBase

Binds this connection to the given Socket. This socket will be used by the connection to send and receive data.

After this method's execution the connection status will be reported as open and the BHttpConnectionBase.isOpen() will return true.

Overrides:

bind in class DefaultBHttpClientConnection

Parameters:

socket - the socket.

Throws:

IOException - in case of an I/O error.

onResponseReceived

protected void onResponseReceived(ClassicHttpResponse response)

Overrides:

onResponseReceived in class DefaultBHttpClientConnection

onRequestSubmitted

protected void onRequestSubmitted(ClassicHttpRequest request)

Overrides:

onRequestSubmitted in class DefaultBHttpClientConnection