Package org.bremersee.ldaptive.reactive

Class ReactiveLdaptiveTemplate

java.lang.Object
org.bremersee.ldaptive.reactive.ReactiveLdaptiveTemplate
All Implemented Interfaces:
ReactiveLdaptiveOperations
public class ReactiveLdaptiveTemplate extends Object implements ReactiveLdaptiveOperations
The reactive ldaptive template.
Author:
Christian Bremer

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactiveLdaptiveTemplate(org.ldaptive.ConnectionFactory connectionFactory)
    Instantiates a new Reactive ldaptive template.

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Mono<org.ldaptive.Result>
    add(org.ldaptive.AddRequest addRequest)
    Executes add operation.
    reactor.core.publisher.Mono<Boolean>
    bind(org.ldaptive.BindRequest bindRequest)
    Executes bind operation.
    reactor.core.publisher.Mono<Boolean>
    compare(org.ldaptive.CompareRequest compareRequest)
    Executes compare operation.
    ReactiveLdaptiveTemplate
    copy()
    Returns a new instance of this ldap operations with the same connection factory and error handler.
    ReactiveLdaptiveTemplate
    copy(LdaptiveErrorHandler errorHandler)
    Returns a new instance of this ldap operations with the same connection factory and the given error handler.
    reactor.core.publisher.Mono<org.ldaptive.Result>
    delete(org.ldaptive.DeleteRequest deleteRequest)
    Executes delete operation.
    reactor.core.publisher.Mono<org.ldaptive.extended.ExtendedResponse>
    executeExtension(org.ldaptive.extended.ExtendedRequest request)
    Executes extended request.
    reactor.core.publisher.Flux<org.ldaptive.LdapEntry>
    findAll(org.ldaptive.SearchRequest searchRequest)
    Find all.
    reactor.core.publisher.Mono<org.ldaptive.LdapEntry>
    findOne(org.ldaptive.SearchRequest searchRequest)
    Find one.
    org.ldaptive.ConnectionFactory
    getConnectionFactory()
    Gets connection factory.
    reactor.core.publisher.Mono<org.ldaptive.Result>
    modify(org.ldaptive.ModifyRequest modifyRequest)
    Executes modify operation.
    reactor.core.publisher.Mono<org.ldaptive.Result>
    modifyDn(org.ldaptive.ModifyDnRequest modifyDnRequest)
    Executes modify DN operation.
    <T> reactor.core.publisher.Mono<T>
    save(T domainObject, LdaptiveEntryMapper<T> entryMapper)
    Save.
    void
    setErrorHandler(LdaptiveErrorHandler errorHandler)
    Sets error handler.

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.bremersee.ldaptive.reactive.ReactiveLdaptiveOperations

    exists, exists, findAll, findOne, generateUserPassword, modifyUserPassword, remove, removeAll, saveAll

  • Constructor Details

    • ReactiveLdaptiveTemplate

      public ReactiveLdaptiveTemplate(org.ldaptive.ConnectionFactory connectionFactory)
      Instantiates a new Reactive ldaptive template.
      Parameters:
      connectionFactory - the connection factory

  • Method Details

    • getConnectionFactory

      public org.ldaptive.ConnectionFactory getConnectionFactory()
      Description copied from interface: ReactiveLdaptiveOperations
      Gets connection factory.
      Specified by:
      getConnectionFactory in interface ReactiveLdaptiveOperations
      Returns:
      the connection factory

    • setErrorHandler

      public void setErrorHandler(LdaptiveErrorHandler errorHandler)
      Sets error handler.
      Parameters:
      errorHandler - the error handler

    • copy

      public ReactiveLdaptiveTemplate copy()
      Description copied from interface: ReactiveLdaptiveOperations
      Returns a new instance of this ldap operations with the same connection factory and error handler.
      Specified by:
      copy in interface ReactiveLdaptiveOperations
      Returns:
      a new instance of this ldap operations

    • copy

      public ReactiveLdaptiveTemplate copy(LdaptiveErrorHandler errorHandler)
      Description copied from interface: ReactiveLdaptiveOperations
      Returns a new instance of this ldap operations with the same connection factory and the given error handler.
      Specified by:
      copy in interface ReactiveLdaptiveOperations
      Parameters:
      errorHandler - the new error handler
      Returns:
      the new instance of this ldap operations

    • add

      public reactor.core.publisher.Mono<org.ldaptive.Result> add(org.ldaptive.AddRequest addRequest)
      Description copied from interface: ReactiveLdaptiveOperations
      Executes add operation.
      Specified by:
      add in interface ReactiveLdaptiveOperations
      Parameters:
      addRequest - the add request
      Returns:
      the mono

    • bind

      public reactor.core.publisher.Mono<Boolean> bind(org.ldaptive.BindRequest bindRequest)
      Description copied from interface: ReactiveLdaptiveOperations
      Executes bind operation.
      Specified by:
      bind in interface ReactiveLdaptiveOperations
      Parameters:
      bindRequest - the bind request
      Returns:
      the mono

    • compare

      public reactor.core.publisher.Mono<Boolean> compare(org.ldaptive.CompareRequest compareRequest)
      Description copied from interface: ReactiveLdaptiveOperations
      Executes compare operation.
      Specified by:
      compare in interface ReactiveLdaptiveOperations
      Parameters:
      compareRequest - the compare request
      Returns:
      the mono

    • delete

      public reactor.core.publisher.Mono<org.ldaptive.Result> delete(org.ldaptive.DeleteRequest deleteRequest)
      Description copied from interface: ReactiveLdaptiveOperations
      Executes delete operation.
      Specified by:
      delete in interface ReactiveLdaptiveOperations
      Parameters:
      deleteRequest - the delete request
      Returns:
      the mono

    • executeExtension

      public reactor.core.publisher.Mono<org.ldaptive.extended.ExtendedResponse> executeExtension(org.ldaptive.extended.ExtendedRequest request)
      Description copied from interface: ReactiveLdaptiveOperations
      Executes extended request.
      Specified by:
      executeExtension in interface ReactiveLdaptiveOperations
      Parameters:
      request - the request
      Returns:
      the mono

    • modify

      public reactor.core.publisher.Mono<org.ldaptive.Result> modify(org.ldaptive.ModifyRequest modifyRequest)
      Description copied from interface: ReactiveLdaptiveOperations
      Executes modify operation.
      Specified by:
      modify in interface ReactiveLdaptiveOperations
      Parameters:
      modifyRequest - the modify request
      Returns:
      the mono

    • modifyDn

      public reactor.core.publisher.Mono<org.ldaptive.Result> modifyDn(org.ldaptive.ModifyDnRequest modifyDnRequest)
      Description copied from interface: ReactiveLdaptiveOperations
      Executes modify DN operation.
      Specified by:
      modifyDn in interface ReactiveLdaptiveOperations
      Parameters:
      modifyDnRequest - the modify dn request
      Returns:
      the mono

    • findOne

      public reactor.core.publisher.Mono<org.ldaptive.LdapEntry> findOne(org.ldaptive.SearchRequest searchRequest)
      Description copied from interface: ReactiveLdaptiveOperations
      Find one.
      Specified by:
      findOne in interface ReactiveLdaptiveOperations
      Parameters:
      searchRequest - the search request
      Returns:
      the mono

    • findAll

      public reactor.core.publisher.Flux<org.ldaptive.LdapEntry> findAll(org.ldaptive.SearchRequest searchRequest)
      Description copied from interface: ReactiveLdaptiveOperations
      Find all.
      Specified by:
      findAll in interface ReactiveLdaptiveOperations
      Parameters:
      searchRequest - the search request
      Returns:
      the flux

    • save

      public <T> reactor.core.publisher.Mono<T> save(T domainObject, LdaptiveEntryMapper<T> entryMapper)
      Description copied from interface: ReactiveLdaptiveOperations
      Save.
      Specified by:
      save in interface ReactiveLdaptiveOperations
      Type Parameters:
      T - the type parameter
      Parameters:
      domainObject - the domain object
      entryMapper - the entry mapper
      Returns:
      the mono