org.springframework.geode.cache.support

Class RepositoryCacheLoaderWriterSupport<T,ID>

java.lang.Object

org.springframework.geode.cache.support.RepositoryCacheLoaderWriterSupport<T,ID>

All Implemented Interfaces:

org.apache.geode.cache.CacheCallback, org.apache.geode.cache.CacheLoader<ID,T>, org.apache.geode.cache.CacheWriter<ID,T>, org.apache.geode.cache.Declarable, org.springframework.beans.factory.Aware, org.springframework.context.EnvironmentAware, CacheLoaderSupport<ID,T>, CacheWriterSupport<ID,T>

Direct Known Subclasses:

RepositoryCacheLoader, RepositoryCacheWriter

public abstract class RepositoryCacheLoaderWriterSupport<T,ID>
extends java.lang.Object
implements CacheLoaderSupport<ID,T>, CacheWriterSupport<ID,T>, org.springframework.context.EnvironmentAware

Abstract base class supporting the implementation of Apache Geode CacheLoaders and CacheWriters backed by Spring Data Repositories.

Since:

1.1.0

See Also:

CacheLoader, CacheWriter, EnvironmentAware, Environment, CrudRepository, Repository, CacheLoaderSupport

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	DATA_ACCESS_ERROR
static java.lang.String	NUKE_AND_PAVE_PROPERTY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RepositoryCacheLoaderWriterSupport(org.springframework.data.repository.CrudRepository<T,ID> repository)

Method Summary

Modifier and Type	Method and Description
protected <S,R> R	doRepositoryOp(S entity, java.util.function.Function<S,R> repositoryOperation)
protected java.util.Optional<org.springframework.core.env.Environment>	getEnvironment()
org.springframework.data.repository.CrudRepository<T,ID>	getRepository()
protected boolean	isNukeAndPaveEnabled()
T	load(org.apache.geode.cache.LoaderHelper<ID,T> helper)
protected abstract org.apache.geode.cache.CacheRuntimeException	newCacheRuntimeException(java.util.function.Supplier<java.lang.String> messageSupplier, java.lang.Throwable cause)
void	setEnvironment(org.springframework.core.env.Environment environment)
<U extends RepositoryCacheLoaderWriterSupport<T,ID>> U	with(org.springframework.core.env.Environment environment)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.geode.cache.support.CacheLoaderSupport

close

Methods inherited from interface org.springframework.geode.cache.support.CacheWriterSupport

beforeCreate, beforeDestroy, beforeRegionClear, beforeRegionDestroy, beforeUpdate

Methods inherited from interface org.apache.geode.cache.Declarable

init, initialize

Field Detail

NUKE_AND_PAVE_PROPERTY

public static final java.lang.String NUKE_AND_PAVE_PROPERTY

See Also:

Constant Field Values

DATA_ACCESS_ERROR

protected static final java.lang.String DATA_ACCESS_ERROR

See Also:

Constant Field Values

Constructor Detail

RepositoryCacheLoaderWriterSupport

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

Method Detail

isNukeAndPaveEnabled

protected boolean isNukeAndPaveEnabled()

setEnvironment

public void setEnvironment(@Nullable
                           org.springframework.core.env.Environment environment)

Specified by:

setEnvironment in interface org.springframework.context.EnvironmentAware

getEnvironment

protected java.util.Optional<org.springframework.core.env.Environment> getEnvironment()

getRepository

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

doRepositoryOp

protected <S,R> R doRepositoryOp(S entity,
                                 java.util.function.Function<S,R> repositoryOperation)

load

public T load(org.apache.geode.cache.LoaderHelper<ID,T> helper)
       throws org.apache.geode.cache.CacheLoaderException

Specified by:

load in interface org.apache.geode.cache.CacheLoader<ID,T>

Throws:

org.apache.geode.cache.CacheLoaderException

newCacheRuntimeException

protected abstract org.apache.geode.cache.CacheRuntimeException newCacheRuntimeException(java.util.function.Supplier<java.lang.String> messageSupplier,
                                                                                         java.lang.Throwable cause)

with

public <U extends RepositoryCacheLoaderWriterSupport<T,ID>> U with(org.springframework.core.env.Environment environment)