public class LateralCacheNoWait<K,V> extends AbstractAuxiliaryCache<K,V>
ICacheType.CacheType
Constructor and Description |
---|
LateralCacheNoWait(LateralCache<K,V> cache)
Constructs with the given lateral cache, and fires up an event queue for asynchronous
processing.
|
Modifier and Type | Method and Description |
---|---|
void |
dispose()
Adds a dispose request to the lateral cache.
|
void |
fixCache(ICacheServiceNonLocal<K,V> lateral)
Replaces the lateral cache service handle with the given handle and reset the queue by
starting up a new instance.
|
ICacheElement<K,V> |
get(K key)
Synchronously reads from the lateral cache.
|
AuxiliaryCacheAttributes |
getAuxiliaryCacheAttributes()
This returns the generic attributes for an auxiliary cache.
|
String |
getCacheName()
Gets the cacheName attribute of the LateralCacheNoWait object
|
ICacheType.CacheType |
getCacheType()
No lateral invocation.
|
String |
getEventLoggingExtraInfo()
this won't be called since we don't do ICache logging here.
|
Set<K> |
getKeySet()
Return the keys in this cache.
|
Map<K,ICacheElement<K,V>> |
getMatching(String pattern)
Synchronously reads from the lateral cache.
|
Map<K,ICacheElement<K,V>> |
getMultiple(Set<K> keys)
Gets multiple items from the cache based on the given set of keys.
|
int |
getSize()
No lateral invocation.
|
IStats |
getStatistics() |
String |
getStats()
getStats
|
CacheStatus |
getStatus()
Returns the asyn cache status.
|
boolean |
remove(K key)
Adds a remove request to the lateral cache.
|
void |
removeAll()
Adds a removeAll request to the lateral cache.
|
void |
resetEventQ()
Resets the event q by first destroying the existing one and starting up new one.
|
String |
toString() |
void |
update(ICacheElement<K,V> ce)
Puts an item to the cache.
|
createICacheEvent, createICacheEvent, getCacheEventLogger, getElementSerializer, getKeyMatcher, logApplicationEvent, logError, logICacheEvent, setCacheEventLogger, setElementSerializer, setKeyMatcher
public LateralCacheNoWait(LateralCache<K,V> cache)
cache
- public void update(ICacheElement<K,V> ce) throws IOException
ICache
ce
- IOException
public ICacheElement<K,V> get(K key)
key
- public Map<K,ICacheElement<K,V>> getMultiple(Set<K> keys)
keys
- public Map<K,ICacheElement<K,V>> getMatching(String pattern)
pattern
- public Set<K> getKeySet() throws IOException
IOException
- if access to the auxiliary cache failsAuxiliaryCache.getKeySet()
public boolean remove(K key)
key
- public void removeAll()
public void dispose()
public int getSize()
public ICacheType.CacheType getCacheType()
public CacheStatus getStatus()
public String getCacheName()
public void fixCache(ICacheServiceNonLocal<K,V> lateral)
lateral
- public void resetEventQ()
public AuxiliaryCacheAttributes getAuxiliaryCacheAttributes()
AuxiliaryCache
public String getEventLoggingExtraInfo()
getEventLoggingExtraInfo
in class AbstractAuxiliaryCache<K,V>
public IStats getStatistics()
Copyright © 2002–2018 The Apache Software Foundation. All rights reserved.