@ThreadSafe public class RemoteStore extends Object implements AdvancedLoadWriteStore
RemoteCacheStoreConfiguration
,
Hotrod Java ClientAdvancedCacheLoader.CacheLoaderTask<K,V>, AdvancedCacheLoader.KeyFilter<K>, AdvancedCacheLoader.TaskContext
AdvancedCacheWriter.PurgeListener<K>
Modifier and Type | Field and Description |
---|---|
protected InitializationContext |
ctx |
Constructor and Description |
---|
RemoteStore() |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Removes all the data from the storage.
|
boolean |
contains(Object key)
Returns true if the storage contains an entry associated with the given key.
|
boolean |
delete(Object key) |
RemoteCacheStoreConfiguration |
getConfiguration() |
RemoteCache<Object,Object> |
getRemoteCache() |
void |
init(InitializationContext ctx)
Used to initialize a cache loader.
|
MarshalledEntry |
load(Object key)
Fetches an entry from the storage.
|
void |
process(AdvancedCacheLoader.KeyFilter filter,
AdvancedCacheLoader.CacheLoaderTask task,
Executor executor,
boolean fetchValue,
boolean fetchMetadata)
Iterates in parallel over the entries in the storage using the threads from the executor pool.
|
void |
purge(Executor threadPool,
AdvancedCacheWriter.PurgeListener task)
Using the thread in the pool, removed all the expired data from the persistence storage.
|
void |
setInternalCacheEntryFactory(InternalEntryFactory iceFactory) |
int |
size()
Returns the number of elements in the store.
|
void |
start() |
void |
stop() |
void |
write(MarshalledEntry entry) |
protected InitializationContext ctx
public void init(InitializationContext ctx)
CacheLoader
PersistenceManager
when setting up cache loaders.init
in interface CacheLoader
init
in interface CacheWriter
public void start() throws CacheLoaderException
start
in interface Lifecycle
CacheLoaderException
public void stop() throws CacheLoaderException
stop
in interface Lifecycle
CacheLoaderException
public MarshalledEntry load(Object key) throws CacheLoaderException
CacheLoader
load
in interface CacheLoader
CacheLoaderException
public boolean contains(Object key) throws CacheLoaderException
CacheLoader
contains
in interface CacheLoader
CacheLoaderException
public void process(AdvancedCacheLoader.KeyFilter filter, AdvancedCacheLoader.CacheLoaderTask task, Executor executor, boolean fetchValue, boolean fetchMetadata)
AdvancedCacheLoader
CacheLoaderTask#processEntry(MarshalledEntry, TaskContext)
is invoked. Before passing an entry
to the callback task, the entry should be validated against the filter. The method should only return once
the iteration is complete.process
in interface AdvancedCacheLoader
filter
- to validate which entries should be feed into the task. Might be null.task
- callback to be invoked in parallel for each stored entry that passes the filter checkexecutor
- a thread pool to be used for parallel iterationfetchValue
- whether or not to fetch the value from the persistent store. E.g. if the iteration is
intended only over the key set, no point fetching the values from the persistent store as
wellfetchMetadata
- whether or not to fetch the metadata from the persistent store. E.g. if the iteration is
intended only ove the key set, then no pint fetching the metadata from the persistent store
as wellpublic int size()
AdvancedCacheLoader
size
in interface AdvancedCacheLoader
public void purge(Executor threadPool, AdvancedCacheWriter.PurgeListener task)
AdvancedCacheWriter
purge
in interface AdvancedCacheWriter
public void write(MarshalledEntry entry) throws CacheLoaderException
write
in interface CacheWriter
CacheLoaderException
public void clear() throws CacheLoaderException
AdvancedCacheWriter
clear
in interface AdvancedCacheWriter
CacheLoaderException
public boolean delete(Object key) throws CacheLoaderException
delete
in interface CacheWriter
CacheLoaderException
public void setInternalCacheEntryFactory(InternalEntryFactory iceFactory)
public RemoteCache<Object,Object> getRemoteCache()
public RemoteCacheStoreConfiguration getConfiguration()
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.