Package org.apache.hc.client5.http.impl.nio

Class DefaultManagedAsyncClientConnection

java.lang.Object

org.apache.hc.client5.http.impl.nio.DefaultManagedAsyncClientConnection

All Implemented Interfaces:

Closeable, AutoCloseable, ManagedAsyncClientConnection, org.apache.hc.core5.http.HttpConnection, org.apache.hc.core5.http.SocketModalCloseable, org.apache.hc.core5.io.ModalCloseable, org.apache.hc.core5.reactor.ssl.TransportSecurityLayer, org.apache.hc.core5.util.Identifiable

final class DefaultManagedAsyncClientConnection
extends Object
implements ManagedAsyncClientConnection, org.apache.hc.core5.util.Identifiable

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	closed
private final org.apache.hc.core5.reactor.IOSession	ioSession
private static final org.slf4j.Logger	LOG
private final org.apache.hc.core5.util.Timeout	socketTimeout

Constructor Summary

Constructors

Constructor	Description
DefaultManagedAsyncClientConnection(org.apache.hc.core5.reactor.IOSession ioSession)

Method Summary

Modifier and Type	Method	Description
void	activate()	Restores the connection from idle mode.
void	close()
void	close(org.apache.hc.core5.io.CloseMode closeMode)
org.apache.hc.core5.http.EndpointDetails	getEndpointDetails()
String	getId()
SocketAddress	getLocalAddress()
org.apache.hc.core5.http.ProtocolVersion	getProtocolVersion()
SocketAddress	getRemoteAddress()
org.apache.hc.core5.util.Timeout	getSocketTimeout()
SSLSession	getSSLSession()
org.apache.hc.core5.reactor.ssl.TlsDetails	getTlsDetails()
boolean	isOpen()
void	passivate()	Puts the connection into idle mode.
void	setSocketTimeout(org.apache.hc.core5.util.Timeout timeout)
void	startTls(SSLContext sslContext, org.apache.hc.core5.net.NamedEndpoint endpoint, org.apache.hc.core5.reactor.ssl.SSLBufferMode sslBufferMode, org.apache.hc.core5.reactor.ssl.SSLSessionInitializer initializer, org.apache.hc.core5.reactor.ssl.SSLSessionVerifier verifier, org.apache.hc.core5.util.Timeout handshakeTimeout)
void	submitCommand(org.apache.hc.core5.reactor.Command command, org.apache.hc.core5.reactor.Command.Priority priority)	Submits the given command for execution.

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

ioSession

private final org.apache.hc.core5.reactor.IOSession ioSession

socketTimeout

private final org.apache.hc.core5.util.Timeout socketTimeout

closed

private final AtomicBoolean closed

Constructor Details

DefaultManagedAsyncClientConnection

public DefaultManagedAsyncClientConnection(org.apache.hc.core5.reactor.IOSession ioSession)

Method Details

getId

public String getId()

Specified by:

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

close

public void close(org.apache.hc.core5.io.CloseMode closeMode)

Specified by:

close in interface org.apache.hc.core5.io.ModalCloseable

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

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

Throws:

IOException

isOpen

public boolean isOpen()

Specified by:

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

setSocketTimeout

public void setSocketTimeout(org.apache.hc.core5.util.Timeout timeout)

Specified by:

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

getSocketTimeout

public org.apache.hc.core5.util.Timeout getSocketTimeout()

Specified by:

getSocketTimeout in interface org.apache.hc.core5.http.SocketModalCloseable

getRemoteAddress

public SocketAddress getRemoteAddress()

Specified by:

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

getLocalAddress

public SocketAddress getLocalAddress()

Specified by:

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

getEndpointDetails

public org.apache.hc.core5.http.EndpointDetails getEndpointDetails()

Specified by:

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

getProtocolVersion

public org.apache.hc.core5.http.ProtocolVersion getProtocolVersion()

Specified by:

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

startTls

public void startTls(SSLContext sslContext,
 org.apache.hc.core5.net.NamedEndpoint endpoint,
 org.apache.hc.core5.reactor.ssl.SSLBufferMode sslBufferMode,
 org.apache.hc.core5.reactor.ssl.SSLSessionInitializer initializer,
 org.apache.hc.core5.reactor.ssl.SSLSessionVerifier verifier,
 org.apache.hc.core5.util.Timeout handshakeTimeout)
              throws UnsupportedOperationException

Specified by:

startTls in interface org.apache.hc.core5.reactor.ssl.TransportSecurityLayer

Throws:

UnsupportedOperationException

getTlsDetails

public org.apache.hc.core5.reactor.ssl.TlsDetails getTlsDetails()

Specified by:

getTlsDetails in interface org.apache.hc.core5.reactor.ssl.TransportSecurityLayer

getSSLSession

public SSLSession getSSLSession()

Specified by:

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

submitCommand

public void submitCommand(org.apache.hc.core5.reactor.Command command,
 org.apache.hc.core5.reactor.Command.Priority priority)

Description copied from interface: ManagedAsyncClientConnection

Submits the given command for execution.

Specified by:

submitCommand in interface ManagedAsyncClientConnection

Parameters:

command - the command to be executed.

priority - the command priority.

passivate

public void passivate()

Description copied from interface: ManagedAsyncClientConnection

Puts the connection into idle mode.

Specified by:

passivate in interface ManagedAsyncClientConnection

activate

public void activate()

Description copied from interface: ManagedAsyncClientConnection

Restores the connection from idle mode.

Specified by:

activate in interface ManagedAsyncClientConnection