|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.infinispan.loaders.AbstractCacheLoader org.infinispan.loaders.cluster.ClusterCacheLoader
public class ClusterCacheLoader
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.
Field Summary |
---|
Fields inherited from class org.infinispan.loaders.AbstractCacheLoader |
---|
marshaller |
Constructor Summary | |
---|---|
ClusterCacheLoader()
|
Method Summary | |
---|---|
Class<? extends CacheLoaderConfig> |
getConfigurationClass()
This method is used by the configuration parser to get a hold of the CacheLoader implementation's corresponding CacheLoaderConfig type. |
void |
init(CacheLoaderConfig config,
Cache cache,
StreamingMarshaller m)
Used to initialize a cache loader. |
protected boolean |
isCacheReady()
A test to check whether the cache is in its started state. |
Set<InternalCacheEntry> |
load(int maxElems)
Loads up to a specific number of entries. |
InternalCacheEntry |
load(Object key)
Loads an entry mapped to by a given key. |
Set<InternalCacheEntry> |
loadAll()
Loads all entries in the loader. |
Set<Object> |
loadAllKeys(Set<Object> keysToExclude)
Loads a set of all keys, excluding a filter set. |
void |
start()
|
void |
stop()
|
Methods inherited from class org.infinispan.loaders.AbstractCacheLoader |
---|
containsKey |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ClusterCacheLoader()
Method Detail |
---|
public void init(CacheLoaderConfig config, Cache cache, StreamingMarshaller m)
CacheLoader
CacheLoaderManager
when setting up cache loaders.
init
in interface CacheLoader
init
in class AbstractCacheLoader
config
- the cache loader configuration beancache
- cache associated with this cache loader. Implementations may use this to determine cache name when
selecting where refer to state in storage, for example, a different database table name.m
- marshaller to use when loading state from a stream, if supported by the implementation.public InternalCacheEntry load(Object key) throws CacheLoaderException
CacheLoader
key
- key
CacheLoaderException
- in the event of problems reading from sourcepublic Set<InternalCacheEntry> loadAll() throws CacheLoaderException
CacheLoader
CacheLoaderException
- in the event of problems reading from sourcepublic Set<InternalCacheEntry> load(int maxElems) throws CacheLoaderException
CacheLoader
maxElems
- maximum number of entries to load
CacheLoaderException
public Set<Object> loadAllKeys(Set<Object> keysToExclude) throws CacheLoaderException
CacheLoader
keysToExclude
- a set of keys to exclude. An empty set or null will indicate that all keys should be returned.
CacheLoaderException
public void start() throws CacheLoaderException
CacheLoaderException
public void stop() throws CacheLoaderException
CacheLoaderException
public Class<? extends CacheLoaderConfig> getConfigurationClass()
CacheLoader
CacheLoaderConfig
type. This is usually done by instantiating the CacheLoader
and then calling this method. This may result in 2 instances being created, however, since the instance
created to get a hold of the configuration type is then discarded and another instance is created for actual
use as a CacheLoader when the cache starts.
Since Infinispan 4.1, you can also annotate your CacheLoader implementation with CacheLoaderMetadata
and provide this information via the annotation, which will prevent unnecessary instances being created.
CacheLoaderConfig
bean used to configure this
implementation of CacheLoader
.protected boolean isCacheReady()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |