org.infinispan.persistence.async

Class AsyncCacheWriter

java.lang.Object

org.infinispan.persistence.support.DelegatingCacheWriter

org.infinispan.persistence.async.AsyncCacheWriter

All Implemented Interfaces:

Lifecycle, CacheWriter

Direct Known Subclasses:

AdvancedAsyncCacheWriter

public class AsyncCacheWriter
extends DelegatingCacheWriter

The AsyncCacheWriter is a delegating CacheStore that buffers changes and writes them asynchronously to the underlying CacheStore.

Read operations are done synchronously, taking into account the current state of buffered changes.

There is no provision for exception handling for problems encountered with the underlying store during a write operation, and the exception is just logged.

When configuring the loader, use the following element:

<async enabled="true" />

to define whether cache loader operations are to be asynchronous. If not specified, a cache loader operation is assumed synchronous and this decorator is not applied.

Write operations affecting same key are now coalesced so that only the final state is actually stored.

Since:

4.0

Author:

Manik Surtani, Galder Zamarreño, Sanne Grinovero, Karsten Blees, Mircea Markus

Field Summary

Fields

Modifier and Type	Field and Description
protected AsyncStoreConfiguration	asyncConfiguration
protected AtomicReference<State>	state
protected org.infinispan.persistence.async.BufferLock	stateLock

Fields inherited from class org.infinispan.persistence.support.DelegatingCacheWriter

actual, ctx

Constructor Summary

Constructors

Constructor and Description
AsyncCacheWriter(CacheWriter delegate)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	applyModificationsSync(List<Modification> mods)
boolean	delete(Object key)
AtomicReference<State>	getState()
void	init(InitializationContext ctx) Used to initialize a cache loader.
void	start()
void	stop()
void	write(MarshalledEntry entry)

Methods inherited from class org.infinispan.persistence.support.DelegatingCacheWriter

undelegate

Methods inherited from class java.lang.Object

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

Field Detail

stateLock

protected org.infinispan.persistence.async.BufferLock stateLock

state

protected final AtomicReference<State> state

asyncConfiguration

protected AsyncStoreConfiguration asyncConfiguration

Constructor Detail

AsyncCacheWriter

public AsyncCacheWriter(CacheWriter delegate)

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

Overrides:

init in class DelegatingCacheWriter

start

public void start()

Specified by:

start in interface Lifecycle

Overrides:

start in class DelegatingCacheWriter

stop

public void stop()

Specified by:

stop in interface Lifecycle

Overrides:

stop in class DelegatingCacheWriter

write

public void write(MarshalledEntry entry)

Specified by:

write in interface CacheWriter

Overrides:

write in class DelegatingCacheWriter

delete

public boolean delete(Object key)

Specified by:

delete in interface CacheWriter

Overrides:

delete in class DelegatingCacheWriter

applyModificationsSync

protected void applyModificationsSync(List<Modification> mods)
                               throws CacheLoaderException

Throws:

CacheLoaderException

getState

public AtomicReference<State> getState()