Class SyncReplClient


  • public class SyncReplClient
    extends java.lang.Object
    Client that simplifies using the sync repl control.
    Author:
    Middleware Services
    • Field Detail

      • logger

        protected final org.slf4j.Logger logger
        Logger for this class.
    • Constructor Detail

      • SyncReplClient

        public SyncReplClient​(ConnectionFactory cf,
                              boolean persist)
        Creates a new sync repl client.
        Parameters:
        cf - to get a connection from
        persist - whether to refresh and persist or just refresh
    • Method Detail

      • getConnectionFactory

        public ConnectionFactory getConnectionFactory()
        Returns the connection factory.
        Returns:
        connection factory
      • setOnEntry

        public void setOnEntry​(java.util.function.Consumer<LdapEntry> consumer)
        Sets the onEntry consumer.
        Parameters:
        consumer - to invoke when an entry is received
      • setOnResult

        public void setOnResult​(java.util.function.Consumer<Result> consumer)
        Sets the onResult consumer.
        Parameters:
        consumer - to invoke when a result is received
      • setOnMessage

        public void setOnMessage​(java.util.function.Consumer<SyncInfoMessage> consumer)
        Sets the onMessage consumer.
        Parameters:
        consumer - to invoke when a sync info message is received
      • setOnException

        public void setOnException​(java.util.function.Consumer<java.lang.Exception> consumer)
        Sets the onException consumer.
        Parameters:
        consumer - to invoke when a sync info message is received
      • isComplete

        public boolean isComplete()
        Returns whether a search result has been received by this client.
        Returns:
        whether a search result has been received
      • close

        public void close()
        Closes the connection factory.
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object