org.infinispan.persistence.support

Class AdvancedSingletonCacheWriter

java.lang.Object

org.infinispan.persistence.support.DelegatingCacheWriter

org.infinispan.persistence.support.SingletonCacheWriter

org.infinispan.persistence.support.AdvancedSingletonCacheWriter

All Implemented Interfaces:

Lifecycle, AdvancedCacheWriter, CacheWriter

public class AdvancedSingletonCacheWriter
extends SingletonCacheWriter
implements AdvancedCacheWriter

Since:

6.0

Author:

Mircea Markus

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.persistence.support.SingletonCacheWriter

SingletonCacheWriter.PushStateException, SingletonCacheWriter.SingletonStoreListener

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

AdvancedCacheWriter.PurgeListener<K>

Field Summary

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

active, executor

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

actual, ctx

Constructor Summary

Constructors

Constructor and Description
AdvancedSingletonCacheWriter(CacheWriter actual, SingletonStoreConfiguration singletonConfiguration)

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.support.SingletonCacheWriter

activeStatusChanged, awaitForPushToFinish, createPushStateTask, delete, pushState, start, stop, toString, write

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

init, undelegate

Methods inherited from class java.lang.Object

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

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

delete, init, write

Methods inherited from interface org.infinispan.commons.api.Lifecycle

start, stop

Constructor Detail

AdvancedSingletonCacheWriter

public AdvancedSingletonCacheWriter(CacheWriter actual,
                                    SingletonStoreConfiguration singletonConfiguration)

Method Detail

clear

public void clear()

Description copied from interface: AdvancedCacheWriter

Removes all the data from the storage.

Specified by:

clear in interface AdvancedCacheWriter

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.

When this method returns all entries will be purged and no tasks will be running due to this loader in the provided executor. If however an exception is thrown there could be tasks still pending or running in the executor.

Specified by:

purge in interface AdvancedCacheWriter