org.springframework.geode.cache

Class RepositoryAsyncEventListener.CreateUpdateAsyncEventRepositoryFunction<T,ID>

java.lang.Object

org.springframework.geode.cache.RepositoryAsyncEventListener.AbstractAsyncEventOperationRepositoryFunction<T,ID>

org.springframework.geode.cache.RepositoryAsyncEventListener.CreateUpdateAsyncEventRepositoryFunction<T,ID>

Type Parameters:

T - type of the entity tied to the event.

ID - type of the identifier of the entity.

All Implemented Interfaces:

java.util.function.Function<org.apache.geode.cache.asyncqueue.AsyncEvent<ID,T>,java.lang.Boolean>, RepositoryAsyncEventListener.AsyncEventOperationRepositoryFunction<T,ID>

Enclosing class:

RepositoryAsyncEventListener<T,ID>

public static class RepositoryAsyncEventListener.CreateUpdateAsyncEventRepositoryFunction<T,ID>
extends RepositoryAsyncEventListener.AbstractAsyncEventOperationRepositoryFunction<T,ID>

An RepositoryAsyncEventListener.AsyncEventOperationRepositoryFunction capable of handling Operation.CREATE and Operation.UPDATE AsyncEvents. Invokes the CrudRepository.save(Object) data access operation.

Constructor Summary

Constructors

Constructor and Description
CreateUpdateAsyncEventRepositoryFunction(RepositoryAsyncEventListener<T,ID> listener) Constructs a new instance of RepositoryAsyncEventListener.CreateUpdateAsyncEventRepositoryFunction initialized with the given, required RepositoryAsyncEventListener.

Method Summary

Modifier and Type	Method and Description
boolean	canProcess(org.apache.geode.cache.asyncqueue.AsyncEvent<ID,T> event) Determines whether the given AsyncEvent can be processed by this Function.
protected <R> R	doRepositoryOp(T entity) Invokes the appropriate Spring Data CrudRepository data access operation based on the AsyncEvent Operation as determined by GatewayQueueEvent.getOperation().

Methods inherited from class org.springframework.geode.cache.RepositoryAsyncEventListener.AbstractAsyncEventOperationRepositoryFunction

apply, getErrorHandler, getListener, getRepository, resolveEntity

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

CreateUpdateAsyncEventRepositoryFunction

public CreateUpdateAsyncEventRepositoryFunction(@NonNull
                                                RepositoryAsyncEventListener<T,ID> listener)

Constructs a new instance of RepositoryAsyncEventListener.CreateUpdateAsyncEventRepositoryFunction initialized with the given, required RepositoryAsyncEventListener.

Parameters:

listener - RepositoryAsyncEventListener forwarding AsyncEvents for processing by this Function

See Also:

RepositoryAsyncEventListener

Method Detail

canProcess

public boolean canProcess(@Nullable
                          org.apache.geode.cache.asyncqueue.AsyncEvent<ID,T> event)

Description copied from interface: RepositoryAsyncEventListener.AsyncEventOperationRepositoryFunction

Determines whether the given AsyncEvent can be processed by this Function. Implementing classes must override this method to specify which AsyncEvent Operations they are capable of processing.

Parameters:

event - AsyncEvent to evaluate.

Returns:

a boolean value indicating whether this Function is capable of processing the given AsyncEvent. Default returns false.

See Also:

AsyncEvent

doRepositoryOp

protected <R> R doRepositoryOp(T entity)

Description copied from class: RepositoryAsyncEventListener.AbstractAsyncEventOperationRepositoryFunction

Invokes the appropriate Spring Data CrudRepository data access operation based on the AsyncEvent Operation as determined by GatewayQueueEvent.getOperation().

Specified by:

doRepositoryOp in class RepositoryAsyncEventListener.AbstractAsyncEventOperationRepositoryFunction<T,ID>

Type Parameters:

R - type of the Spring Data CrudRepository data access operation return value.

Parameters:

entity - entity to process.

Returns:

the result of invoking the Spring Data CrudRepository data access operation.

See Also:

CrudRepository