Package 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 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	Description
protected static final String	DATA_ACCESS_ERROR
static final String	NUKE_AND_PAVE_PROPERTY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected <S, R> R	doRepositoryOp(S entity, Function<S,R> repositoryOperation)
protected 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(Supplier<String> messageSupplier, 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 Details

NUKE_AND_PAVE_PROPERTY

public static final String NUKE_AND_PAVE_PROPERTY

See Also:

• Constant Field Values

DATA_ACCESS_ERROR

protected static final String DATA_ACCESS_ERROR

See Also:

• Constant Field Values

Constructor Details

RepositoryCacheLoaderWriterSupport

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

Method Details

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 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,
 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<T,ID>

Throws:

org.apache.geode.cache.CacheLoaderException

newCacheRuntimeException

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

with

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