CacheProxy (Hazelcast Root 3.4-EA API)

java.lang.Object
- com.hazelcast.cache.impl.CacheProxy<K,V>

Type Parameters:
K - the type of key.
V - the type of value.

All Implemented Interfaces:

ICache<K,V>, Closeable, AutoCloseable, Iterable<javax.cache.Cache.Entry<K,V>>, javax.cache.Cache<K,V>
```
public class CacheProxy<K,V>
extends Object
```
ICache implementation

This proxy is the implementation of ICache and javax.cache.Cache which is returned by HazelcastServerCacheManager. It represents a cache for server or embedded mode.

Each cache method actually is an operation which is sent to related partition(s) or node(s). Operations are executed on partition's or node's executor pools and the results are delivered to the user.

In order to access a CacheProxy by name, a cacheManager should be used. It's advised to use ICache instead.

Nested Class Summary
- Nested classes/interfaces inherited from interface javax.cache.Cache
  javax.cache.Cache.Entry<K,V>

Field Summary

Fields
Modifier and Type	Field and Description
`protected CacheConfig<K,V>`	`cacheConfig`
`protected ICacheService`	`cacheService`
`protected ILogger`	`logger`
`protected String`	`name`
`protected String`	`nameWithPrefix`
`protected CacheOperationProvider`	`operationProvider`
`protected SerializationService`	`serializationService`

Constructor Summary

Constructors
Modifier	Constructor and Description
`protected`	`CacheProxy(CacheConfig cacheConfig, NodeEngine nodeEngine, ICacheService cacheService, HazelcastServerCacheManager cacheManager)`

Method Summary

Methods
Modifier and Type	Method and Description
`protected void`	`addListenerLocally(String regId, javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)`
`void`	`clear()`
`protected void`	`clearInternal()`
`void`	`close()`
`protected void`	`closeCacheLoader()`
`protected void`	`closeListeners()`
`boolean`	`containsKey(K key)`
`protected void`	`countDownCompletionLatch(int id)`
`void`	`deregisterAllCacheEntryListener(Collection<String> listenerRegistrations)`
`void`	`deregisterCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)`
`protected void`	`deregisterCompletionLatch(Integer countDownLatchId)`
`protected void`	`deregisterCompletionListener()`
`void`	`destroy()`
`protected void`	`ensureOpen()`
`V`	`get(K key)`
`V`	`get(K key, javax.cache.expiry.ExpiryPolicy expiryPolicy)` Gets a key with custom expiry policy.
`Map<K,V>`	`getAll(Set<? extends K> keys)`
`Map<K,V>`	`getAll(Set<? extends K> keys, javax.cache.expiry.ExpiryPolicy expiryPolicy)` getAll operation with custom expiry policy.
`V`	`getAndPut(K key, V value)`
`V`	`getAndPut(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` getAndPut operation with custom expiry policy.
`ICompletableFuture<V>`	`getAndPutAsync(K key, V value)` Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed.
`ICompletableFuture<V>`	`getAndPutAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed using a custom expiry policy.
`V`	`getAndRemove(K key)`
`ICompletableFuture<V>`	`getAndRemoveAsync(K key)` Asynchronously removes the entry for a key returning the removed value if one existed.
`V`	`getAndReplace(K key, V value)`
`V`	`getAndReplace(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` getAndReplace operation with custom expiry policy.
`ICompletableFuture<V>`	`getAndReplaceAsync(K key, V value)` Asynchronously replaces the entry for a key only if it is currently mapped to some value.
`ICompletableFuture<V>`	`getAndReplaceAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` Asynchronously replaces the entry for a key only if it is currently mapped to some value using custom expiry policy.
`InternalCompletableFuture<V>`	`getAsync(K key)` Asynchronously gets an entry from cache.
`InternalCompletableFuture<V>`	`getAsync(K key, javax.cache.expiry.ExpiryPolicy expiryPolicy)` Asynchronously gets an entry from cache with a provided expiry policy.
`javax.cache.CacheManager`	`getCacheManager()`
`<C extends javax.cache.configuration.Configuration<K,V>> C`	`getConfiguration(Class<C> clazz)`
`protected String`	`getDistributedObjectName()`
`CacheStatistics`	`getLocalCacheStatistics()` Directly access to local Cache Statistics.
`String`	`getName()`
`protected NodeEngine`	`getNodeEngine()`
`protected ICacheService`	`getService()`
`protected String`	`getServiceName()`
`<T> T`	`invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... arguments)`
`protected <T> InternalCompletableFuture<T>`	`invoke(Operation op, Data keyData, boolean completionOperation)`
`<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>`	`invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... arguments)`
`boolean`	`isClosed()`
`Iterator<javax.cache.Cache.Entry<K,V>>`	`iterator()`
`void`	`loadAll(Set<? extends K> keys, boolean replaceExistingValues, javax.cache.integration.CompletionListener completionListener)`
`void`	`put(K key, V value)`
`void`	`put(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` put operation with custom expiry policy.
`void`	`putAll(Map<? extends K,? extends V> map)`
`void`	`putAll(Map<? extends K,? extends V> map, javax.cache.expiry.ExpiryPolicy expiryPolicy)` putAll operation with custom expiry policy.
`InternalCompletableFuture<Void>`	`putAsync(K key, V value)` Asynchronously associates the specified value with the specified key in the cache.
`InternalCompletableFuture<Void>`	`putAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` Asynchronously associates the specified value with the specified key in the cache using a custom expiry policy.
`protected <T> InternalCompletableFuture<T>`	`putAsyncInternal(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy, boolean isGet, boolean withCompletionEvent)`
`boolean`	`putIfAbsent(K key, V value)`
`boolean`	`putIfAbsent(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` putIfAbsent operation with custom expiry policy.
`InternalCompletableFuture<Boolean>`	`putIfAbsentAsync(K key, V value)` Asynchronously associates the specified value with the specified key in the cache if not already exist.
`InternalCompletableFuture<Boolean>`	`putIfAbsentAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` Asynchronously associates the specified value with the specified key in the cache if not already exist, using a custom expiry policy.
`protected InternalCompletableFuture<Boolean>`	`putIfAbsentAsyncInternal(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy, boolean withCompletionEvent)`
`void`	`registerCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)`
`protected Integer`	`registerCompletionLatch(int count)`
`protected void`	`registerCompletionListener()`
`boolean`	`remove(K key)`
`boolean`	`remove(K key, V oldValue)`
`void`	`removeAll()`
`void`	`removeAll(Set<? extends K> keys)`
`protected void`	`removeAllInternal(Set<? extends K> keys)`
`InternalCompletableFuture<Boolean>`	`removeAsync(K key)` Asynchronously removes the mapping for a key from this cache if it is present.
`InternalCompletableFuture<Boolean>`	`removeAsync(K key, V oldValue)` Asynchronously removes the mapping for a key only if it is currently mapped to the given value.
`protected <T> InternalCompletableFuture<T>`	`removeAsyncInternal(K key, V oldValue, boolean hasOldValue, boolean isGet, boolean withCompletionEvent)`
`protected String`	`removeListenerLocally(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)`
`boolean`	`replace(K key, V value)`
`boolean`	`replace(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` replace operation with custom expiry policy.
`boolean`	`replace(K key, V oldValue, V newValue)`
`boolean`	`replace(K key, V oldValue, V newValue, javax.cache.expiry.ExpiryPolicy expiryPolicy)` replace operation with custom expiry policy.
`ICompletableFuture<Boolean>`	`replaceAsync(K key, V value)` Asynchronously replaces the entry for a key.
`ICompletableFuture<Boolean>`	`replaceAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)` Asynchronously replaces the entry for a key only if it is currently mapped to some value.
`ICompletableFuture<Boolean>`	`replaceAsync(K key, V oldValue, V newValue)` Asynchronously replaces the entry for a key only if it is currently mapped to a given value.
`ICompletableFuture<Boolean>`	`replaceAsync(K key, V oldValue, V newValue, javax.cache.expiry.ExpiryPolicy expiryPolicy)` Asynchronously replaces the entry for a key only if it is currently mapped to a given value using custom expiry policy.
`protected <T> InternalCompletableFuture<T>`	`replaceAsyncInternal(K key, V oldValue, V newValue, javax.cache.expiry.ExpiryPolicy expiryPolicy, boolean hasOldValue, boolean isGet, boolean withCompletionEvent)`
`int`	`size()` Total entry count.
`protected void`	`submitLoadAllTask(OperationFactory operationFactory, javax.cache.integration.CompletionListener completionListener)`
`<T> T`	`unwrap(Class<T> clazz)`
`protected void`	`updateCacheListenerConfigOnOtherNodes(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration, boolean isRegister)`
`protected void`	`validateCacheLoader(javax.cache.integration.CompletionListener completionListener)`
`protected void`	`waitCompletionLatch(Integer countDownLatchId)`
`protected void`	`waitCompletionLatch(Integer countDownLatchId, int offset)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.hazelcast.cache.ICache
destroy

Methods inherited from interface javax.cache.Cache
close, isClosed

- Field Detail
  - logger
```
protected final ILogger logger
```
  - cacheConfig
```
protected final CacheConfig<K,V> cacheConfig
```
  - name
```
protected final String name
```
  - nameWithPrefix
```
protected final String nameWithPrefix
```
  - cacheService
```
protected final ICacheService cacheService
```
  - serializationService
```
protected final SerializationService serializationService
```
  - operationProvider
```
protected final CacheOperationProvider operationProvider
```
- Constructor Detail
  - CacheProxy
```
protected CacheProxy(CacheConfig cacheConfig,
          NodeEngine nodeEngine,
          ICacheService cacheService,
          HazelcastServerCacheManager cacheManager)
```
- Method Detail
  - 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()
```
  - getConfiguration
```
public <C extends javax.cache.configuration.Configuration<K,V>> C getConfiguration(Class<C> clazz)
```
  - 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)
```
  - getName
```
public String getName()
```
  - getCacheManager
```
public javax.cache.CacheManager getCacheManager()
```
  - unwrap
```
public <T> T unwrap(Class<T> clazz)
```
  - registerCacheEntryListener
```
public void registerCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)
```
  - deregisterCacheEntryListener
```
public void deregisterCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)
```
  - updateCacheListenerConfigOnOtherNodes
```
protected void updateCacheListenerConfigOnOtherNodes(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration,
                                         boolean isRegister)
```
  - iterator
```
public Iterator<javax.cache.Cache.Entry<K,V>> iterator()
```
  - getAsync
```
public InternalCompletableFuture<V> getAsync(K key)
```
    Description copied from interface: ICache
    
    Asynchronously gets an entry from cache.
    
    Parameters:
    key - the key whose associated value is to be returned.
    
    Returns:
    Future from which the value of the key can be retrieved.
    See Also:
    javax.cache.Cache#get(K), ICompletableFuture
  - getAsync
```
public InternalCompletableFuture<V> getAsync(K key,
                                    javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    Asynchronously gets an entry from cache with a provided expiry policy.
    
    Parameters:
    key - the key whose associated value is to be returned.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    Future from which the value of the key can be retrieved.
    See Also:
    javax.cache.Cache#get(K), ICompletableFuture
  - putAsync
```
public InternalCompletableFuture<Void> putAsync(K key,
                                       V value)
```
    Description copied from interface: ICache
    
    Asynchronously associates the specified value with the specified key in the cache.
    
    Parameters:
    key - the key whose associated value is to be returned.
    value - the value to be associated with the specified key.
    
    Returns:
    Future
    See Also:
    javax.cache.Cache#put(K,V), ICompletableFuture
  - putAsync
```
public InternalCompletableFuture<Void> putAsync(K key,
                                       V value,
                                       javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    Asynchronously associates the specified value with the specified key in the cache using a custom expiry policy.
    
    Parameters:
    key - the key whose associated value is to be returned.
    value - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    Future
    See Also:
    javax.cache.Cache#put(K,V), ICompletableFuture
  - putIfAbsentAsync
```
public InternalCompletableFuture<Boolean> putIfAbsentAsync(K key,
                                                  V value)
```
    Description copied from interface: ICache
    
    Asynchronously associates the specified value with the specified key in the cache if not already exist.
    
    Parameters:
    key - the key with which the specified value is to be associated.
    value - the value to be associated with the specified key.
    
    Returns:
    See Also:
    javax.cache.Cache#putIfAbsent(K,V), ICompletableFuture
  - putIfAbsentAsync
```
public InternalCompletableFuture<Boolean> putIfAbsentAsync(K key,
                                                  V value,
                                                  javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    Asynchronously associates the specified value with the specified key in the cache if not already exist, using a custom expiry policy.
    
    Parameters:
    key - the key with which the specified value is to be associated.
    value - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    javax.cache.Cache#putIfAbsent(K,V), ICompletableFuture
  - getAndPutAsync
```
public ICompletableFuture<V> getAndPutAsync(K key,
                                   V value)
```
    Description copied from interface: ICache
    
    Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed.
    
    Parameters:
    key - the key whose associated value is to be returned.
    value - the value to be associated with the specified key.
    
    Returns:
    Future
    See Also:
    javax.cache.Cache#getAndPut(K,V), ICompletableFuture
  - getAndPutAsync
```
public ICompletableFuture<V> getAndPutAsync(K key,
                                   V value,
                                   javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed using a custom expiry policy.
    
    Parameters:
    key - the key whose associated value is to be returned.
    value - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    Future
    See Also:
    javax.cache.Cache#getAndPut(K,V), ICompletableFuture
  - removeAsync
```
public InternalCompletableFuture<Boolean> removeAsync(K key)
```
    Description copied from interface: ICache
    
    Asynchronously removes the mapping for a key from this cache if it is present.
    
    Parameters:
    key - the key whose associated value is to be returned.
    
    Returns:
    Future
    See Also:
    javax.cache.Cache#remove(K), ICompletableFuture
  - removeAsync
```
public InternalCompletableFuture<Boolean> removeAsync(K key,
                                             V oldValue)
```
    Description copied from interface: ICache
    
    Asynchronously removes the mapping for a key only if it is currently mapped to the given value.
    
    Parameters:
    key - the key whose associated value is to be returned.
    oldValue - the value expected to be associated with the specified key.
    
    Returns:
    Future
    See Also:
    javax.cache.Cache#remove(K,V), ICompletableFuture
  - getAndRemoveAsync
```
public ICompletableFuture<V> getAndRemoveAsync(K key)
```
    Description copied from interface: ICache
    
    Asynchronously removes the entry for a key returning the removed value if one existed.
    
    Parameters:
    key - the key whose associated value is to be returned.
    
    Returns:
    Future
    See Also:
    javax.cache.Cache#getAndRemove(K), ICompletableFuture
  - replaceAsync
```
public ICompletableFuture<Boolean> replaceAsync(K key,
                                       V value)
```
    Description copied from interface: ICache
    
    Asynchronously replaces the entry for a key.
    
    Parameters:
    key - the key whose associated value is to be returned.
    value - the value to be associated with the specified key.
    
    Returns:
    Future
    See Also:
    javax.cache.Cache#replace(K,V), ICompletableFuture
  - replaceAsync
```
public ICompletableFuture<Boolean> replaceAsync(K key,
                                       V value,
                                       javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    Asynchronously replaces the entry for a key only if it is currently mapped to some value.
    
    Parameters:
    key - the key with which the specified value is associated.
    value - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    javax.cache.Cache#replace(K,V), ICompletableFuture
  - replaceAsync
```
public ICompletableFuture<Boolean> replaceAsync(K key,
                                       V oldValue,
                                       V newValue)
```
    Description copied from interface: ICache
    
    Asynchronously replaces the entry for a key only if it is currently mapped to a given value.
    
    Parameters:
    key - the key with which the specified value is associated.
    oldValue - the value expected to be associated with the specified key.
    newValue - the value to be associated with the specified key.
    
    Returns:
    See Also:
    javax.cache.Cache#replace(K,V,V), ICompletableFuture
  - replaceAsync
```
public ICompletableFuture<Boolean> replaceAsync(K key,
                                       V oldValue,
                                       V newValue,
                                       javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    Asynchronously replaces the entry for a key only if it is currently mapped to a given value using custom expiry policy.
    
    Parameters:
    key - the key with which the specified value is associated.
    oldValue - the value expected to be associated with the specified key.
    newValue - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    javax.cache.Cache#replace(K,V,V), ICompletableFuture
  - getAndReplaceAsync
```
public ICompletableFuture<V> getAndReplaceAsync(K key,
                                       V value)
```
    Description copied from interface: ICache
    
    Asynchronously replaces the entry for a key only if it is currently mapped to some value.
    
    Parameters:
    key - the key with which the specified value is associated.
    value - the value to be associated with the specified key.
    
    Returns:
    See Also:
    javax.cache.Cache#getAndReplace(K,V), ICompletableFuture
  - getAndReplaceAsync
```
public ICompletableFuture<V> getAndReplaceAsync(K key,
                                       V value,
                                       javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    Asynchronously replaces the entry for a key only if it is currently mapped to some value using custom expiry policy.
    
    Parameters:
    key - the key with which the specified value is associated.
    value - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    javax.cache.Cache#getAndReplace(K,V), ICompletableFuture
  - get
```
public V get(K key,
    javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    Gets a key with custom expiry policy.
    
    Parameters:
    key - the key whose associated value is to be returned.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    javax.cache.Cache#get(K), ICompletableFuture
  - getAll
```
public Map<K,V> getAll(Set<? extends K> keys,
              javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    getAll operation with custom expiry policy.
    
    Parameters:
    keys - the keys whose associated values are to be returned.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    Cache.getAll(java.util.Set), ICompletableFuture
  - put
```
public void put(K key,
       V value,
       javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    put operation with custom expiry policy.
    
    Parameters:
    key - the key with which the specified value is to be associated.
    value - value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    See Also:
    javax.cache.Cache#put(K,V), ICompletableFuture
  - getAndPut
```
public V getAndPut(K key,
          V value,
          javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    getAndPut operation with custom expiry policy.
    
    Parameters:
    key - the key with which the specified value is to be associated.
    value - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    javax.cache.Cache#getAndPut(K,V), ICompletableFuture
  - putAll
```
public void putAll(Map<? extends K,? extends V> map,
          javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    putAll operation with custom expiry policy.
    
    Parameters:
    map - the mappings to be stored in this cache.
    expiryPolicy - custom expiry policy for this operation.
    See Also:
    Cache.putAll(java.util.Map), ICompletableFuture
  - putIfAbsent
```
public boolean putIfAbsent(K key,
                  V value,
                  javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    putIfAbsent operation with custom expiry policy.
    
    Parameters:
    key - the key with which the specified value is to be associated.
    value - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    javax.cache.Cache#putIfAbsent(K,V), ICompletableFuture
  - replace
```
public boolean replace(K key,
              V oldValue,
              V newValue,
              javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    replace operation with custom expiry policy.
    
    Parameters:
    key - the key with which the specified value is associated.
    oldValue - the value expected to be associated with the specified key.
    newValue - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    javax.cache.Cache#replace(K,V,V), ICompletableFuture
  - replace
```
public boolean replace(K key,
              V value,
              javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    replace operation with custom expiry policy.
    
    Parameters:
    key - the key with which the specified value is associated.
    value - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
  - getAndReplace
```
public V getAndReplace(K key,
              V value,
              javax.cache.expiry.ExpiryPolicy expiryPolicy)
```
    Description copied from interface: ICache
    
    getAndReplace operation with custom expiry policy.
    
    Parameters:
    key - the key with which the specified value is associated.
    value - the value to be associated with the specified key.
    expiryPolicy - custom expiry policy for this operation.
    
    Returns:
    See Also:
    javax.cache.Cache#getAndReplace(K,V), ICompletableFuture
  - size
```
public int size()
```
    Description copied from interface: ICache
    
    Total entry count.
    
    Returns:
    total entry count
  - getLocalCacheStatistics
```
public CacheStatistics getLocalCacheStatistics()
```
    Description copied from interface: ICache
    
    Directly access to local Cache Statistics.
    
    Returns:
    CacheStatistics instance or an empty statistics if not enabled
  - invoke
```
protected <T> InternalCompletableFuture<T> invoke(Operation op,
                                      Data keyData,
                                      boolean completionOperation)
```
  - removeAsyncInternal
```
protected <T> InternalCompletableFuture<T> removeAsyncInternal(K key,
                                                   V oldValue,
                                                   boolean hasOldValue,
                                                   boolean isGet,
                                                   boolean withCompletionEvent)
```
  - replaceAsyncInternal
```
protected <T> InternalCompletableFuture<T> replaceAsyncInternal(K key,
                                                    V oldValue,
                                                    V newValue,
                                                    javax.cache.expiry.ExpiryPolicy expiryPolicy,
                                                    boolean hasOldValue,
                                                    boolean isGet,
                                                    boolean withCompletionEvent)
```
  - putAsyncInternal
```
protected <T> InternalCompletableFuture<T> putAsyncInternal(K key,
                                                V value,
                                                javax.cache.expiry.ExpiryPolicy expiryPolicy,
                                                boolean isGet,
                                                boolean withCompletionEvent)
```
  - putIfAbsentAsyncInternal
```
protected InternalCompletableFuture<Boolean> putIfAbsentAsyncInternal(K key,
                                                          V value,
                                                          javax.cache.expiry.ExpiryPolicy expiryPolicy,
                                                          boolean withCompletionEvent)
```
  - clearInternal
```
protected void clearInternal()
```
  - removeAllInternal
```
protected void removeAllInternal(Set<? extends K> keys)
```
  - addListenerLocally
```
protected void addListenerLocally(String regId,
                      javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)
```
  - removeListenerLocally
```
protected String removeListenerLocally(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)
```
  - deregisterAllCacheEntryListener
```
public void deregisterAllCacheEntryListener(Collection<String> listenerRegistrations)
```
  - closeListeners
```
protected void closeListeners()
```
  - countDownCompletionLatch
```
protected void countDownCompletionLatch(int id)
```
  - registerCompletionLatch
```
protected Integer registerCompletionLatch(int count)
```
  - deregisterCompletionLatch
```
protected void deregisterCompletionLatch(Integer countDownLatchId)
```
  - waitCompletionLatch
```
protected void waitCompletionLatch(Integer countDownLatchId)
```
  - waitCompletionLatch
```
protected void waitCompletionLatch(Integer countDownLatchId,
                       int offset)
```
  - registerCompletionListener
```
protected void registerCompletionListener()
```
  - deregisterCompletionListener
```
protected void deregisterCompletionListener()
```
  - ensureOpen
```
protected void ensureOpen()
```
  - close
```
public void close()
```
  - destroy
```
public void destroy()
```
  - isClosed
```
public boolean isClosed()
```
  - getDistributedObjectName
```
protected String getDistributedObjectName()
```
  - getServiceName
```
protected String getServiceName()
```
  - getService
```
protected ICacheService getService()
```
  - getNodeEngine
```
protected NodeEngine getNodeEngine()
```
  - validateCacheLoader
```
protected void validateCacheLoader(javax.cache.integration.CompletionListener completionListener)
```
  - closeCacheLoader
```
protected void closeCacheLoader()
```
  - submitLoadAllTask
```
protected void submitLoadAllTask(OperationFactory operationFactory,
                     javax.cache.integration.CompletionListener completionListener)
```

Class CacheProxy<K,V>

ICache implementation

Nested Class Summary

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

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface com.hazelcast.cache.ICache

Methods inherited from interface javax.cache.Cache

Field Detail

logger

cacheConfig

name

nameWithPrefix

cacheService

serializationService

operationProvider

Constructor Detail

CacheProxy

Method Detail

get

getAll

containsKey

loadAll

put

getAndPut

putAll

putIfAbsent

remove

remove

getAndRemove

replace

replace

getAndReplace

removeAll

removeAll

clear

getConfiguration

invoke

invokeAll

getName

getCacheManager

unwrap

registerCacheEntryListener

deregisterCacheEntryListener

updateCacheListenerConfigOnOtherNodes

iterator

getAsync

getAsync

putAsync

putAsync

putIfAbsentAsync

putIfAbsentAsync

getAndPutAsync

getAndPutAsync

removeAsync

removeAsync

getAndRemoveAsync

replaceAsync

replaceAsync

replaceAsync

replaceAsync

getAndReplaceAsync

getAndReplaceAsync

get

getAll

put

getAndPut

putAll

putIfAbsent

replace

replace

getAndReplace

size

getLocalCacheStatistics

invoke

removeAsyncInternal

replaceAsyncInternal

putAsyncInternal