Package org.infinispan.persistence.support

Class DelegatingCacheWriter<K,V>

java.lang.Object

org.infinispan.persistence.support.DelegatingCacheWriter<K,V>

All Implemented Interfaces:

Lifecycle, CacheWriter<K,V>

Direct Known Subclasses:

AsyncCacheWriter

public abstract class DelegatingCacheWriter<K,V>
extends java.lang.Object
implements CacheWriter<K,V>

Since:

6.0

Author:

Mircea Markus

Field Summary

Fields

Modifier and Type	Field	Description
protected CacheWriter<K,V>	actual
protected InitializationContext	ctx

Constructor Summary

Constructors

Constructor	Description
DelegatingCacheWriter(CacheWriter<K,V> actual)

Method Summary

Modifier and Type	Method	Description
boolean	delete(java.lang.Object key)
void	init(InitializationContext ctx)	Used to initialize a cache loader.
void	start()	Invoked on component start
void	stop()	Invoked on component stop
CacheWriter	undelegate()
void	write(MarshallableEntry<? extends K,? extends V> entry)	Persists the entry to the storage.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.persistence.spi.CacheWriter

bulkUpdate, deleteBatch, isAvailable, write, writeBatch

Field Detail

actual

protected final CacheWriter<K,V> actual

ctx

protected InitializationContext ctx

Constructor Detail

DelegatingCacheWriter

public DelegatingCacheWriter(CacheWriter<K,V> actual)

Method Detail

init

public void init(InitializationContext ctx)

Description copied from interface: CacheWriter

Used to initialize a cache loader. Typically invoked by the PersistenceManager when setting up cache loaders.

Specified by:

init in interface CacheWriter<K,V>

start

public void start()

Description copied from interface: Lifecycle

Invoked on component start

Specified by:

start in interface Lifecycle

stop

public void stop()

Description copied from interface: Lifecycle

Invoked on component stop

Specified by:

stop in interface Lifecycle

write

public void write(MarshallableEntry<? extends K,? extends V> entry)

Description copied from interface: CacheWriter

Persists the entry to the storage.

Specified by:

write in interface CacheWriter<K,V>

See Also:

MarshallableEntry

delete

public boolean delete(java.lang.Object key)

Specified by:

delete in interface CacheWriter<K,V>

Returns:

true if the entry existed in the persistent store and it was deleted.

undelegate

public CacheWriter undelegate()