Class ClusterLoader
java.lang.Object
org.infinispan.persistence.cluster.ClusterLoader
- All Implemented Interfaces:
Lifecycle,org.infinispan.persistence.manager.PersistenceManager.StoreChangeListener,CacheLoader,LocalOnlyCacheLoader
@Deprecated
public class ClusterLoader
extends Object
implements CacheLoader, LocalOnlyCacheLoader, org.infinispan.persistence.manager.PersistenceManager.StoreChangeListener
Deprecated.
since 11.0. To be removed in 14.0 ISPN-11864 with no direct replacement.
Cache loader that consults other members in the cluster for values. A
remoteCallTimeout property is
required, a long that specifies in milliseconds how long to wait for results before returning a null.- Author:
- Mircea.Markus@jboss.com
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanDeprecated.Returns true if the storage contains an entry associated with the given key.voidDeprecated.Used to initialize a cache loader.protected booleanDeprecated.A test to check whether the cache is in its started state.Deprecated.Fetches an entry from the storage.voidstart()Deprecated.Invoked on component startvoidstop()Deprecated.Invoked on component stopvoidstoreChanged(org.infinispan.persistence.manager.PersistenceStatus status) Deprecated.Methods inherited from interface org.infinispan.persistence.spi.CacheLoader
isAvailable
-
Constructor Details
-
ClusterLoader
public ClusterLoader()Deprecated.
-
-
Method Details
-
init
Deprecated.Description copied from interface:CacheLoaderUsed to initialize a cache loader. Typically invoked by thePersistenceManagerwhen setting up cache loaders.- Specified by:
initin interfaceCacheLoader
-
loadEntry
Deprecated.Description copied from interface:CacheLoaderFetches an entry from the storage. If aMarshallableEntryneeds to be created here,InitializationContext.getMarshallableEntryFactory()()} andInitializationContext.getByteBufferFactory()should be used.- Specified by:
loadEntryin interfaceCacheLoader- Returns:
- the entry, or null if the entry does not exist
- Throws:
PersistenceException- in case of an error, e.g. communicating with the external storage
-
contains
Deprecated.Description copied from interface:CacheLoaderReturns true if the storage contains an entry associated with the given key.- Specified by:
containsin interfaceCacheLoader
-
start
public void start()Deprecated.Description copied from interface:LifecycleInvoked on component start -
storeChanged
public void storeChanged(org.infinispan.persistence.manager.PersistenceStatus status) Deprecated. -
stop
public void stop()Deprecated.Description copied from interface:LifecycleInvoked on component stop -
isCacheReady
protected boolean isCacheReady()Deprecated.A test to check whether the cache is in its started state. If not, calls should not be made as the channel may not have properly started, blocks due to state transfers may be in progress, etc.- Returns:
- true if the cache is in its STARTED state.
-