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

Constructor Summary

Constructors

Constructor and Description
PersistenceManagerImpl()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	activate(Object key)
void	clearAllStores(boolean skipSharedStores) Invokes AdvancedCacheWriter.clear() on all the stores that aloes it.
protected AsyncCacheWriter	createAsyncWriter(CacheWriter writer)
boolean	deleteFromAllStores(Object key, boolean skipSharedStore)
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)
MarshalledEntry	loadFromAllStores(Object key, InvocationContext context)
void	preload() Loads the data from the external store into memory during cache startup.
void	processOnAllStores(AdvancedCacheLoader.KeyFilter keyFilter, AdvancedCacheLoader.CacheLoaderTask task, boolean fetchValue, boolean fetchMetadata)
void	purgeExpired() Removes the expired entries from all the existing storage.
int	size()
void	start()
void	stop()
void	writeToAllStores(MarshalledEntry marshalledEntry, boolean skipSharedStores)

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)

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void 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

activate

public boolean activate(Object key)

Specified by:

activate in interface PersistenceManager

clearAllStores

public void clearAllStores(boolean skipSharedStores)

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,
                          boolean skipSharedStore)

Specified by:

deleteFromAllStores in interface PersistenceManager

processOnAllStores

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

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,
                    boolean skipSharedStores)

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

getAllLoaders

public List<CacheLoader> getAllLoaders()

getAllWriters

public List<CacheWriter> getAllWriters()

createAsyncWriter

protected AsyncCacheWriter createAsyncWriter(CacheWriter writer)

getPersistenceExecutor

public Executor getPersistenceExecutor()

getMarshaller

public StreamingMarshaller getMarshaller()