Package com.tangosol.coherence.jcache.remotecache

Class RemoteCache<K,V>

java.lang.Object

com.tangosol.coherence.jcache.AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

com.tangosol.coherence.jcache.remotecache.RemoteCache<K,V>

Type Parameters:

K - key type

V - value type

All Implemented Interfaces:

CoherenceBasedCache<K,V>, Closeable, AutoCloseable, Iterable<javax.cache.Cache.Entry<K,V>>, javax.cache.Cache<K,V>

public class RemoteCache<K,V>
extends AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

A remote partitioned-cache implementation of a Cache based on a Coherence <partitioned-cache>.

Since:

12.2.1

Author:

jf 2014.05.21

Nested Class Summary

Nested classes/interfaces inherited from interface javax.cache.Cache

javax.cache.Cache.Entry<K extends Object,V extends Object>

Field Summary

Fields inherited from class com.tangosol.coherence.jcache.AbstractCoherenceBasedCache

m_configuration, m_manager, m_namedCache, m_sJCacheName

Fields inherited from interface com.tangosol.coherence.jcache.CoherenceBasedCache

JCACHE_CONFIG_BACK_SCHEME_NAME, JCACHE_CONFIG_BACK_SCHEME_SERVICE_NAME, JCACHE_CONFIG_CACHE_NAME, JCACHE_CONFIG_SCHEME_NAME, JCACHE_CONFIG_SERVICE_NAME, JCACHE_EXTEND_PROXY_SERVICE_NAME, JCACHE_EXTEND_SCHEME_NAME, JCACHE_EXTEND_SERVICE_NAME, JCACHE_LOCAL_CACHE_NAME_PATTERN, JCACHE_LOCAL_CACHE_NAME_PREFIX, JCACHE_LOCAL_SCHEME_NAME, JCACHE_LOCAL_SERVICE_NAME, JCACHE_PARTITIONED_CACHE_NAME_PATTERN, JCACHE_PARTITIONED_CACHE_NAME_PREFIX, JCACHE_PARTITIONED_SCHEME_NAME, JCACHE_PARTITIONED_SERVICE_NAME, JCACHE_REMOTE_SCHEME

Constructor Summary

Constructors

Constructor	Description
RemoteCache(CoherenceBasedCacheManager manager, String sJCacheName, RemoteCacheConfiguration configuration)	Constructs a RemoteCache configured by PartitionedCacheConfiguration in context of CoherenceBasedCacheManager with JCache name sJCacheName.

Method Summary

Modifier and Type	Method	Description
void	clear()
void	close()
boolean	containsKey(K key)
void	deregisterCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)
void	destroy()	Destroys a CoherenceBasedCache due to a request from a CoherenceBasedCacheManager.
V	get(K key)
Map<K,V>	getAll(Set<? extends K> keys)
V	getAndPut(K key, V value)
V	getAndRemove(K key)
V	getAndReplace(K key, V value)
<T extends javax.cache.configuration.Configuration<K,V>> T	getConfiguration(Class<T> clz)
JCacheIdentifier	getIdentifier()	Obtain the internal identifier used for JCache caches.
javax.cache.management.CacheMXBean	getMBean()	Get JMX Bean associated with Cache.
JCacheStatistics	getStatistics()	Get JCache Statistics associated with Cache.
<T> T	invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... arguments)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... arguments)
boolean	isStatisticsEnabled()	Get JCache Statistics status
Iterator<javax.cache.Cache.Entry<K,V>>	iterator()
void	loadAll(Set<? extends K> keys, boolean replaceExistingValues, javax.cache.integration.CompletionListener completionListener)
void	onBeforeClosing()	Closes a CoherenceBasedCache at the request of a call to Cache.close().
void	put(K key, V value)
void	putAll(Map<? extends K,? extends V> map)
boolean	putIfAbsent(K key, V value)
void	registerCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)
boolean	remove(K key)
boolean	remove(K key, V oldValue)
void	removeAll()
void	removeAll(Set<? extends K> keys)
boolean	replace(K key, V value)
boolean	replace(K key, V oldValue, V newValue)
void	setManagementEnabled(boolean fEnabled)	Set JCache Management status.
void	setStatisticsEnabled(boolean fEnabled)	Set JCache statistics status
<T> T	unwrap(Class<T> clz)

Methods inherited from class com.tangosol.coherence.jcache.AbstractCoherenceBasedCache

ensureOpen, getCacheManager, getClassLoader, getName, isClosed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

RemoteCache

public RemoteCache(CoherenceBasedCacheManager manager,
                   String sJCacheName,
                   RemoteCacheConfiguration configuration)

Constructs a RemoteCache configured by PartitionedCacheConfiguration in context of CoherenceBasedCacheManager with JCache name sJCacheName.

Parameters:

manager - CacheManager manages the created RemoteCache.

sJCacheName - JCache cache name that must be unique within CoherenceBasedCacheManager context

configuration - remote JCache cache configuration

Method Detail

onBeforeClosing

public void onBeforeClosing()

Description copied from class: AbstractCoherenceBasedCache

Closes a CoherenceBasedCache at the request of a call to Cache.close().

Specified by:

onBeforeClosing in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

getMBean

public javax.cache.management.CacheMXBean getMBean()

Description copied from class: AbstractCoherenceBasedCache

Get JMX Bean associated with Cache.

Specified by:

getMBean in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

Returns:

JMX Bean

getStatistics

public JCacheStatistics getStatistics()

Description copied from class: AbstractCoherenceBasedCache

Get JCache Statistics associated with Cache.

Specified by:

getStatistics in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

Returns:

JCache Statistics if exist or null.

setManagementEnabled

public void setManagementEnabled(boolean fEnabled)

Description copied from class: AbstractCoherenceBasedCache

Set JCache Management status.

Specified by:

setManagementEnabled in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

Parameters:

fEnabled - true to enable

setStatisticsEnabled

public void setStatisticsEnabled(boolean fEnabled)

Description copied from class: AbstractCoherenceBasedCache

Set JCache statistics status

Specified by:

setStatisticsEnabled in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

Parameters:

fEnabled - true to enable

isStatisticsEnabled

public boolean isStatisticsEnabled()

Description copied from class: AbstractCoherenceBasedCache

Get JCache Statistics status

Specified by:

isStatisticsEnabled in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

Returns:

true if enabled, otherwise false

getIdentifier

public JCacheIdentifier getIdentifier()

Description copied from interface: CoherenceBasedCache

Obtain the internal identifier used for JCache caches.

Specified by:

getIdentifier in interface CoherenceBasedCache<K,V>

Specified by:

getIdentifier in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

Returns:

the internal JCacheIdentifier

destroy

public void destroy()

Description copied from interface: CoherenceBasedCache

Destroys a CoherenceBasedCache due to a request from a CoherenceBasedCacheManager.

get

public V get(K key)

getAll

public Map<K,V> getAll(Set<? extends K> keys)

containsKey

public boolean containsKey(K key)

loadAll

public void loadAll(Set<? extends K> keys,
                    boolean replaceExistingValues,
                    javax.cache.integration.CompletionListener completionListener)

put

public void put(K key,
                V value)

getAndPut

public V getAndPut(K key,
                   V value)

putAll

public void putAll(Map<? extends K,? extends V> map)

putIfAbsent

public boolean putIfAbsent(K key,
                           V value)

remove

public boolean remove(K key)

remove

public boolean remove(K key,
                      V oldValue)

getAndRemove

public V getAndRemove(K key)

replace

public boolean replace(K key,
                       V oldValue,
                       V newValue)

replace

public boolean replace(K key,
                       V value)

getAndReplace

public V getAndReplace(K key,
                       V value)

removeAll

public void removeAll(Set<? extends K> keys)

removeAll

public void removeAll()

clear

public void clear()

invoke

public <T> T invoke(K key,
                    javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                    Object... arguments)
             throws javax.cache.processor.EntryProcessorException

Throws:

javax.cache.processor.EntryProcessorException

invokeAll

public <T> Map<K,javax.cache.processor.EntryProcessorResult<T>> invokeAll(Set<? extends K> keys,
                                                                                javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                                Object... arguments)

registerCacheEntryListener

public void registerCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)

deregisterCacheEntryListener

public void deregisterCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)

iterator

public Iterator<javax.cache.Cache.Entry<K,V>> iterator()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface javax.cache.Cache<K,V>

Specified by:

close in interface Closeable

Overrides:

close in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

getConfiguration

public <T extends javax.cache.configuration.Configuration<K,V>> T getConfiguration(Class<T> clz)

Specified by:

getConfiguration in interface javax.cache.Cache<K,V>

Overrides:

getConfiguration in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>

unwrap

public <T> T unwrap(Class<T> clz)

Specified by:

unwrap in interface javax.cache.Cache<K,V>

Overrides:

unwrap in class AbstractCoherenceBasedCache<K,V,RemoteCacheConfiguration<K,V>>