org.infinispan.persistence.manager

Class PersistenceManagerImpl

java.lang.Object

org.infinispan.persistence.manager.PersistenceManagerImpl

All Implemented Interfaces:

Lifecycle, PersistenceManager

public class PersistenceManagerImpl
extends Object
implements PersistenceManager

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.persistence.manager.PersistenceManager

PersistenceManager.AccessMode

Constructor Summary

Constructors

Constructor and Description
PersistenceManagerImpl()

Method Summary

Modifier and Type	Method and Description
void	clearAllStores(PersistenceManager.AccessMode mode) Invokes AdvancedCacheWriter.clear() on all the stores that aloes it.
protected AsyncCacheWriter	createAsyncWriter(CacheWriter writer)
boolean	deleteFromAllStores(Object key, PersistenceManager.AccessMode mode)
void	disableStore(String storeType) Marks the given storage as disabled.
List<CacheLoader>	getAllLoaders()
List<CacheWriter>	getAllWriters()
StreamingMarshaller	getMarshaller()
Executor	getPersistenceExecutor()
AdvancedCacheLoader	getStateTransferProvider() Returns the store one configured with fetch persistent state, or null if none exist.
<T> Set<T>	getStores(Class<T> storeClass)
Collection<String>	getStoresAsString()
void	inject(AdvancedCache<Object,Object> cache, StreamingMarshaller marshaller, Configuration configuration, TransactionManager transactionManager, TimeService timeService, ExecutorService persistenceExecutor, ByteBufferFactory byteBufferFactory, MarshalledEntryFactory marshalledEntryFactory, CacheStoreFactoryRegistry cacheStoreFactoryRegistry, ExpirationManager expirationManager)
MarshalledEntry	loadFromAllStores(Object key, InvocationContext context)
void	preload() Loads the data from the external store into memory during cache startup.
void	processOnAllStores(Executor executor, KeyFilter keyFilter, AdvancedCacheLoader.CacheLoaderTask task, boolean fetchValue, boolean fetchMetadata)
void	processOnAllStores(Executor executor, KeyFilter keyFilter, AdvancedCacheLoader.CacheLoaderTask task, boolean fetchValue, boolean fetchMetadata, PersistenceManager.AccessMode mode)
void	processOnAllStores(KeyFilter keyFilter, AdvancedCacheLoader.CacheLoaderTask task, boolean fetchValue, boolean fetchMetadata)
void	processOnAllStores(KeyFilter keyFilter, AdvancedCacheLoader.CacheLoaderTask task, boolean fetchValue, boolean fetchMetadata, PersistenceManager.AccessMode mode)
void	purgeExpired() Removes the expired entries from all the existing storage.
void	setClearOnStop(boolean clearOnStop)
int	size()
void	start() Invoked on component start
void	stop() Invoked on component stop
void	writeToAllStores(MarshalledEntry marshalledEntry, PersistenceManager.AccessMode mode)

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistenceManagerImpl

public PersistenceManagerImpl()

Method Detail

inject

public void inject(AdvancedCache<Object,Object> cache,
                   StreamingMarshaller marshaller,
                   Configuration configuration,
                   TransactionManager transactionManager,
                   TimeService timeService,
                   ExecutorService persistenceExecutor,
                   ByteBufferFactory byteBufferFactory,
                   MarshalledEntryFactory marshalledEntryFactory,
                   CacheStoreFactoryRegistry cacheStoreFactoryRegistry,
                   ExpirationManager expirationManager)

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

preload

public void preload()

Description copied from interface: PersistenceManager

Loads the data from the external store into memory during cache startup.

Specified by:

preload in interface PersistenceManager

disableStore

public void disableStore(String storeType)

Description copied from interface: PersistenceManager

Marks the given storage as disabled.

Specified by:

disableStore in interface PersistenceManager

getStores

public <T> Set<T> getStores(Class<T> storeClass)

Specified by:

getStores in interface PersistenceManager

getStoresAsString

public Collection<String> getStoresAsString()

Specified by:

getStoresAsString in interface PersistenceManager

purgeExpired

public void purgeExpired()

Description copied from interface: PersistenceManager

Removes the expired entries from all the existing storage.

Specified by:

purgeExpired in interface PersistenceManager

clearAllStores

public void clearAllStores(PersistenceManager.AccessMode mode)

Description copied from interface: PersistenceManager

Invokes AdvancedCacheWriter.clear() on all the stores that aloes it.

Specified by:

clearAllStores in interface PersistenceManager

deleteFromAllStores

public boolean deleteFromAllStores(Object key,
                                   PersistenceManager.AccessMode mode)

Specified by:

deleteFromAllStores in interface PersistenceManager

processOnAllStores

public void processOnAllStores(KeyFilter keyFilter,
                               AdvancedCacheLoader.CacheLoaderTask task,
                               boolean fetchValue,
                               boolean fetchMetadata)

Specified by:

processOnAllStores in interface PersistenceManager

processOnAllStores

public void processOnAllStores(Executor executor,
                               KeyFilter keyFilter,
                               AdvancedCacheLoader.CacheLoaderTask task,
                               boolean fetchValue,
                               boolean fetchMetadata)

Specified by:

processOnAllStores in interface PersistenceManager

processOnAllStores

public void processOnAllStores(KeyFilter keyFilter,
                               AdvancedCacheLoader.CacheLoaderTask task,
                               boolean fetchValue,
                               boolean fetchMetadata,
                               PersistenceManager.AccessMode mode)

Specified by:

processOnAllStores in interface PersistenceManager

processOnAllStores

public void processOnAllStores(Executor executor,
                               KeyFilter keyFilter,
                               AdvancedCacheLoader.CacheLoaderTask task,
                               boolean fetchValue,
                               boolean fetchMetadata,
                               PersistenceManager.AccessMode mode)

Specified by:

processOnAllStores in interface PersistenceManager

loadFromAllStores

public MarshalledEntry loadFromAllStores(Object key,
                                         InvocationContext context)

Specified by:

loadFromAllStores in interface PersistenceManager

writeToAllStores

public void writeToAllStores(MarshalledEntry marshalledEntry,
                             PersistenceManager.AccessMode mode)

Specified by:

writeToAllStores in interface PersistenceManager

getStateTransferProvider

public AdvancedCacheLoader getStateTransferProvider()

Description copied from interface: PersistenceManager

Returns the store one configured with fetch persistent state, or null if none exist.

Specified by:

getStateTransferProvider in interface PersistenceManager

size

public int size()

Specified by:

size in interface PersistenceManager

setClearOnStop

public void setClearOnStop(boolean clearOnStop)

Specified by:

setClearOnStop in interface PersistenceManager

getAllLoaders

public List<CacheLoader> getAllLoaders()

getAllWriters

public List<CacheWriter> getAllWriters()

createAsyncWriter

protected AsyncCacheWriter createAsyncWriter(CacheWriter writer)

getPersistenceExecutor

public Executor getPersistenceExecutor()

getMarshaller

public StreamingMarshaller getMarshaller()