org.infinispan.persistence.async

Class AdvancedAsyncCacheWriter

java.lang.Object

org.infinispan.persistence.support.DelegatingCacheWriter

org.infinispan.persistence.async.AsyncCacheWriter

org.infinispan.persistence.async.AdvancedAsyncCacheWriter

All Implemented Interfaces:

Lifecycle, AdvancedCacheWriter, CacheWriter

public class AdvancedAsyncCacheWriter
extends AsyncCacheWriter
implements AdvancedCacheWriter

Since:

6.0

Author:

Mircea Markus

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.persistence.spi.AdvancedCacheWriter

AdvancedCacheWriter.PurgeListener<K>

Field Summary

Fields inherited from class org.infinispan.persistence.async.AsyncCacheWriter

asyncConfiguration, state, stateLock

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

actual, ctx

Constructor Summary

Constructors

Constructor and Description
AdvancedAsyncCacheWriter(CacheWriter delegate)

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all the data from the storage.
void	purge(Executor threadPool, AdvancedCacheWriter.PurgeListener task) Using the thread in the pool, removed all the expired data from the persistence storage.

Methods inherited from class org.infinispan.persistence.async.AsyncCacheWriter

applyModificationsSync, delete, getState, init, start, stop, write

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

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

delete, init, write

Methods inherited from interface org.infinispan.lifecycle.Lifecycle

start, stop

Constructor Detail

AdvancedAsyncCacheWriter

public AdvancedAsyncCacheWriter(CacheWriter delegate)

Method Detail

purge

public void purge(Executor threadPool,
                  AdvancedCacheWriter.PurgeListener task)

Description copied from interface: AdvancedCacheWriter

Using the thread in the pool, removed all the expired data from the persistence storage. For each removed entry, the supplied listener is invoked.

Specified by:

purge in interface AdvancedCacheWriter

clear

public void clear()

Description copied from interface: AdvancedCacheWriter

Removes all the data from the storage.

Specified by:

clear in interface AdvancedCacheWriter