Class TargetConnections


  • public class TargetConnections
    extends Object
    Manages the connection from transport to the back end servers. It keeps track of the connections for host:port pair.
    • Constructor Detail

      • TargetConnections

        public TargetConnections​(org.apache.http.nio.reactor.ConnectingIOReactor ioReactor,
                                 TargetConfiguration targetConfiguration,
                                 ConnectCallback callback)
        Create a TargetConnections with the given IO-Reactor
        Parameters:
        ioReactor - the IO-Reactor
        targetConfiguration - the configuration of the sender
        callback - the callback
    • Method Detail

      • getConnection

        public org.apache.http.nio.NHttpClientConnection getConnection​(org.apache.http.conn.routing.HttpRoute route,
                                                                       org.apache.axis2.context.MessageContext msgContext,
                                                                       TargetErrorHandler targetErrorHandler,
                                                                       Queue<org.apache.axis2.context.MessageContext> queue)
        Return a connection to the host:port pair. If a connection is not available return null. If the particular host:port allows to create more connections this method will try to connect asynchronously. If the connection is successful it will be notified in a separate thread.
        Parameters:
        route - Http route
        Returns:
        Either returns a connection if already available or returns null and notifies the delivery agent when the connection is available
      • getExistingConnection

        public org.apache.http.nio.NHttpClientConnection getExistingConnection​(org.apache.http.conn.routing.HttpRoute route)
      • shutdownConnection

        public void shutdownConnection​(org.apache.http.nio.NHttpClientConnection conn)
        This connection is no longer valid. So we need to shutdownConnection connection.
        Parameters:
        conn - connection to shutdownConnection
      • shutdownConnection

        public void shutdownConnection​(org.apache.http.nio.NHttpClientConnection conn,
                                       boolean isError)
        This connection is no longer valid. So we need to shutdownConnection connection.
        Parameters:
        conn - connection to shutdownConnection
        isError - whether an error is causing this shutdown of the connection. It is very important to set this flag correctly. When an error causing the shutdown of the connections we should not release associated writer buffer to the pool as it might lead into situations like same buffer is getting released to both source and target buffer factories
      • closeConnection

        public void closeConnection​(org.apache.http.nio.NHttpClientConnection conn,
                                    boolean isError)
        Close a connection gracefully.
        Parameters:
        conn - the connection that needs to be closed.
        isError - whether an error is causing the close of the connection. When an error is causing a close of a connection we should not release the associated buffers into the pool.
      • releaseConnection

        public void releaseConnection​(org.apache.http.nio.NHttpClientConnection conn)
        Release an active connection to the pool
        Parameters:
        conn - connection to be released
      • addConnection

        public void addConnection​(org.apache.http.nio.NHttpClientConnection conn)
        This method is called when a new connection is made.
        Parameters:
        conn - connection to the target server
      • resetConnectionPool

        public void resetConnectionPool​(Set<String> hostList)
        Shutdown the connections of the given host:port list. This will allow to create new connection at the next request happens.
        Parameters:
        hostList - Set of String which contains entries in hots:port format