Package org.bremersee.data.ldaptive.reactive

Class ReactiveLdaptiveTemplate

java.lang.Object

org.bremersee.data.ldaptive.reactive.ReactiveLdaptiveTemplate

All Implemented Interfaces:

Cloneable, ReactiveLdaptiveOperations

public class ReactiveLdaptiveTemplate
extends Object
implements ReactiveLdaptiveOperations, Cloneable

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.
ReactiveLdaptiveTemplate	clone()	Returns a new instance of this ldaptive template with the same connection factory and error handler.
ReactiveLdaptiveTemplate	clone(LdaptiveErrorHandler errorHandler)	Returns a new instance of this ldaptive template with the same connection factory and the given error handler.
reactor.core.publisher.Mono<Boolean>	compare(org.ldaptive.CompareRequest compareRequest)	Executes compare operation.
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

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

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

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

Constructor Detail

ReactiveLdaptiveTemplate

public ReactiveLdaptiveTemplate(org.ldaptive.ConnectionFactory connectionFactory)

Instantiates a new Reactive ldaptive template.

Parameters:

connectionFactory - the connection factory

Method Detail

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

clone

public ReactiveLdaptiveTemplate clone()

Returns a new instance of this ldaptive template with the same connection factory and error handler.

Overrides:

clone in class Object

Returns:

a new instance of this ldaptive template

clone

public ReactiveLdaptiveTemplate clone(LdaptiveErrorHandler errorHandler)

Returns a new instance of this ldaptive template with the same connection factory and the given error handler.

Parameters:

errorHandler - the new error handler

Returns:

the new instance of the ldaptive template

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