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
    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, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.ssl.TransportSecurityLayer> callback)
     
    void
    submitCommand(org.apache.hc.core5.reactor.Command command, org.apache.hc.core5.reactor.Command.Priority priority)
    Submits the given command for execution.
    void
    switchProtocol(String protocolId, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.ProtocolIOSession> callback)
    Switches this I/O session to the application protocol with the given ID.

    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, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.ssl.TransportSecurityLayer> callback) throws UnsupportedOperationException
      Specified by:
      startTls in interface org.apache.hc.core5.reactor.ssl.TransportSecurityLayer
      Throws:
      UnsupportedOperationException

    • 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

    • switchProtocol

      public void switchProtocol(String protocolId, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.ProtocolIOSession> callback) throws UnsupportedOperationException
      Description copied from interface: ManagedAsyncClientConnection
      Switches this I/O session to the application protocol with the given ID.
      Specified by:
      switchProtocol in interface ManagedAsyncClientConnection
      Parameters:
      protocolId - the application protocol ID
      callback - the result callback
      Throws:
      UnsupportedOperationException - if application protocol switch is not supported.