Method Details

• getErrorHandler

  protected RepositoryAsyncEventListener.AsyncEventErrorHandler getErrorHandler()

  Alias to the configured RepositoryAsyncEventListener RepositoryAsyncEventListener.AsyncEventErrorHandler.

  Returns:

  the configured RepositoryAsyncEventListener.AsyncEventErrorHandler; never null.

  See Also:

  • RepositoryAsyncEventListener.getAsyncEventErrorHandler()
  • RepositoryAsyncEventListener.AsyncEventErrorHandler
  • getListener()

• getListener

  @NonNull protected RepositoryAsyncEventListener<T,ID> getListener()

  Returns a reference to the associated RepositoryAsyncEventListener.

  Returns:

  a reference to the associated RepositoryAsyncEventListener; never null.

  See Also:

  • RepositoryAsyncEventListener

• getRepository

  @NonNull protected org.springframework.data.repository.CrudRepository<T,ID> getRepository()

  Alias to the configured RepositoryAsyncEventListener CrudRepository.

  Returns:

  the configured CrudRepository; never null.

  See Also:

  • CrudRepository
  • RepositoryAsyncEventListener.getRepository()
  • getListener()

• apply

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

  Processes the given AsyncEvent by first determining whether the event can be processed by this Function, and then proceeds to extract the entity associated with the event to invoke the appropriate Spring Data CrudRepository data access operation determined by the AsyncEvent Operation. If an error is thrown while processing the AsyncEvent, then the RepositoryAsyncEventListener.AsyncEventErrorHandler is called to handle the error and perform any necessary/required post-processing actions. RepositoryAsyncEventListener.AsyncEventErrorHandler can be implemented to retry the operation with incremental backoff, based on count or time, record the failure, perform resource cleanup actions, whatever is necessary and appropriate to the application use case.

  Specified by:

  apply in interface Function<T,ID>

  Parameters:

  event - AsyncEvent to process.

  Returns:

  a boolean value indicating whether the event was successfully processed.

  Throws:

  IllegalStateException - if the resolve entity is null.

  See Also:

  • AsyncEvent
  • RepositoryAsyncEventListener.AsyncEventErrorHandler
  • RepositoryAsyncEventListener.AsyncEventOperationRepositoryFunction.canProcess(AsyncEvent)
  • doRepositoryOp(Object)
  • resolveEntity(AsyncEvent)
  • getErrorHandler()

• doRepositoryOp

  protected abstract <R> R doRepositoryOp(@NonNull T entity)

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

  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

• resolveEntity

  protected T resolveEntity(@NonNull org.apache.geode.cache.asyncqueue.AsyncEvent<ID,T> event)

  Resolves the entity associated with the AsyncEvent.

  Parameters:

  event - AsyncEvent from which to resolve the entity.

  Returns:

  the resolve entity from the AsyncEvent.

  Throws:

  IllegalArgumentException - if AsyncEvent is null.

  IllegalStateException - if the resolved entity is null.

  See Also:

  • GatewayQueueEvent.getDeserializedValue()
  • AsyncEvent