Class Connections


  • public final class Connections
    extends Object
    This class contains methods for creating and manipulating LDAP clients and connections.
    • Method Detail

      • newInternalConnection

        public static Connection newInternalConnection​(io.reactivex.rxjava3.functions.BiFunction<Integer,​Request,​io.reactivex.rxjava3.core.Flowable<Response>> requestHandler)
        Creates a new Connection which will route requests to the provided requestHandler.

        When processing requests, requestHandler implementations are passed a pseudo request ID which is incremented for each successive internal request on a per client connection basis. The request ID may be useful for logging purposes.

        An internal connection does not require requestHandler implementations to return a result when processing requests. However, it is recommended that implementations do always return results even for abandoned requests. This is because application client threads may block indefinitely waiting for results.

        Parameters:
        requestHandler - The request handler which will be used for all client connections.
        Returns:
        The new internal connection.
        Throws:
        NullPointerException - If requestHandler was null.
      • newInternalConnectionFactory

        public static ConnectionFactory newInternalConnectionFactory​(io.reactivex.rxjava3.functions.BiFunction<Integer,​Request,​io.reactivex.rxjava3.core.Flowable<Response>> requestHandler)
        Creates a new ConnectionFactory which will route requests to the provided requestHandler.

        When processing requests, requestHandler implementations are passed a pseudo request ID which is incremented for each successive internal request on a per client connection basis. The request ID may be useful for logging purposes.

        An internal connection does not require requestHandler implementations to return a result when processing requests. However, it is recommended that implementations do always return results even for abandoned requests. This is because application client threads may block indefinitely waiting for results.

        Parameters:
        requestHandler - The request handler which will be used for all client connections.
        Returns:
        The new internal LDAP client.
        Throws:
        NullPointerException - If requestHandler was null.
      • uncloseable

        public static ConnectionFactory uncloseable​(ConnectionFactory factory)
        Returns an uncloseable view of the provided connection factory. Attempts to call ConnectionFactory.close() will be ignored.
        Parameters:
        factory - The connection factory whose close method is to be disabled.
        Returns:
        An uncloseable view of the provided connection factory.