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. AremoteCallTimeout
property is required, along
that specifies in milliseconds how long to wait for results before returning a null.- Author:
- Mircea.Markus@jboss.com
-
-
Constructor Summary
Constructors Constructor Description ClusterLoader()
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description boolean
contains(Object key)
Deprecated.Returns true if the storage contains an entry associated with the given key.void
init(InitializationContext ctx)
Deprecated.Used to initialize a cache loader.protected boolean
isCacheReady()
Deprecated.A test to check whether the cache is in its started state.MarshallableEntry
loadEntry(Object key)
Deprecated.Fetches an entry from the storage.void
start()
Deprecated.Invoked on component startvoid
stop()
Deprecated.Invoked on component stopvoid
storeChanged(org.infinispan.persistence.manager.PersistenceStatus status)
Deprecated.-
Methods inherited from interface org.infinispan.persistence.spi.CacheLoader
isAvailable
-
-
-
-
Method Detail
-
init
public void init(InitializationContext ctx)
Deprecated.Description copied from interface:CacheLoader
Used to initialize a cache loader. Typically invoked by thePersistenceManager
when setting up cache loaders.- Specified by:
init
in interfaceCacheLoader
-
loadEntry
public MarshallableEntry loadEntry(Object key) throws PersistenceException
Deprecated.Description copied from interface:CacheLoader
Fetches an entry from the storage. If aMarshallableEntry
needs to be created here,InitializationContext.getMarshallableEntryFactory()
()} andInitializationContext.getByteBufferFactory()
should be used.- Specified by:
loadEntry
in 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
public boolean contains(Object key)
Deprecated.Description copied from interface:CacheLoader
Returns true if the storage contains an entry associated with the given key.- Specified by:
contains
in interfaceCacheLoader
-
start
public void start()
Deprecated.Description copied from interface:Lifecycle
Invoked on component start
-
storeChanged
public void storeChanged(org.infinispan.persistence.manager.PersistenceStatus status)
Deprecated.
-
stop
public void stop()
Deprecated.Description copied from interface:Lifecycle
Invoked 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.
-
-