com.hazelcast.client.cache.impl

Class NearCachedClientCacheProxy<K,V>

java.lang.Object

com.hazelcast.client.impl.spi.ClientProxy

com.hazelcast.client.cache.impl.ClientCacheProxy<K,V>

com.hazelcast.client.cache.impl.NearCachedClientCacheProxy<K,V>

Type Parameters:

K - the type of key.

V - the type of value.

All Implemented Interfaces:

ICache<K,V>, CacheSyncListenerCompleter, ICacheInternal<K,V>, DistributedObject, PrefixedDistributedObject, EventJournalReader<EventJournalCacheEvent<K,V>>, Closeable, AutoCloseable, Iterable<javax.cache.Cache.Entry<K,V>>, javax.cache.Cache<K,V>

public class NearCachedClientCacheProxy<K,V>
extends ClientCacheProxy<K,V>

An ICacheInternal implementation which handles Near Cache specific behaviour of methods.

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 String	name
protected String	nameWithPrefix
protected int	partitionCount

Method Summary

Modifier and Type	Method and Description
protected void	addListenerLocally(UUID regId, javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration, CacheEventListenerAdaptor<K,V> adaptor)
UUID	addNearCacheInvalidationListener(EventHandler eventHandler)
void	clear()
protected void	clearInternal()
void	close()
protected boolean	containsKeyInternal(Object key)
void	countDownCompletionLatch(int countDownLatchId)
protected void	ensureOpen()
protected void	getAllInternal(Set<? extends K> keys, Collection<Data> dataKeys, javax.cache.expiry.ExpiryPolicy expiryPolicy, List<Object> resultingKeyValuePairs, long startNanos)
protected <T> InternalCompletableFuture<T>	getAndRemoveAsyncInternal(K key)
protected <T> ClientDelegatingFuture<T>	getAndRemoveSyncInternal(K key)
protected InternalCompletableFuture<V>	getAsyncInternal(Object key, javax.cache.expiry.ExpiryPolicy expiryPolicy, BiConsumer<V,Throwable> callback)
javax.cache.CacheManager	getCacheManager()
protected String	getDistributedObjectName()
protected UUID	getListenerIdLocal(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)
protected ILogger	getLogger()
NearCache	getNearCache()
String	getPrefixedName() Returns the unique prefixed name for this DistributedObject.
protected V	getSyncInternal(Object key, javax.cache.expiry.ExpiryPolicy expiryPolicy)
protected void	injectDependencies(Object obj)
protected <T> T	invoke(ClientMessage clientMessage)
protected ClientInvocationFuture	invoke(ClientMessage req, Data keyData, int completionId)
protected ClientInvocationFuture	invoke(ClientMessage req, int partitionId, int completionId)
protected Object	invokeInternal(Object key, Data epData, Object[] arguments)
boolean	isClosed()
boolean	isDestroyed() Determines whether this Cache instance has been destroyed.
protected void	loadAllInternal(Set<? extends K> keys, List<Data> dataKeys, boolean replaceExistingValues, javax.cache.integration.CompletionListener completionListener)
protected BiConsumer<V,Throwable>	newStatsCallbackOrNull(boolean isGet)
protected long	nowInNanosOrDefault()
protected void	onDestroy() Called before proxy is destroyed.
protected <T> void	onGetAndRemoveAsyncInternal(K key, Data keyData, ClientDelegatingFuture<T> delegatingFuture, BiConsumer<T,Throwable> callback)
protected void	onInitialize() Called when proxy is created.
protected void	onPutIfAbsentAsyncInternal(K key, V value, Data keyData, Data valueData, ClientDelegatingFuture<Boolean> delegatingFuture, BiConsumer<Boolean,Throwable> callback)
protected void	onPutIfAbsentSyncInternal(K key, V value, Data keyData, Data valueData)
protected void	onPutSyncInternal(K key, V value, Data keyData, Data valueData)
protected void	onRemoveAsyncInternal(Object key, Data keyData, ClientDelegatingFuture future, BiConsumer<Object,Throwable> callback)
void	onRemoveSyncInternal(Object key, Data keyData)
protected <T> void	onReplaceAndGetAsync(K key, V value, Data keyData, Data valueData, ClientDelegatingFuture<T> delegatingFuture, BiConsumer<T,Throwable> callback)
protected <T> void	onReplaceInternalAsync(K key, V value, Data keyData, Data valueData, ClientDelegatingFuture<T> delegatingFuture, BiConsumer<T,Throwable> callback)
void	open() Opens cache if available (not destroyed).
protected void	postDestroy() Called after proxy is destroyed.
protected boolean	preDestroy() Called before proxy is destroyed and determines whether destroy should be done.
protected void	putAllInternal(Map<? extends K,? extends V> map, javax.cache.expiry.ExpiryPolicy expiryPolicy, Map<Object,Data> keyMap, List<Map.Entry<Data,Data>>[] entriesPerPartition, long startNanos)
protected ClientDelegatingFuture	putAsyncInternal(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy, boolean isGet, boolean withCompletionEvent, BiConsumer<V,Throwable> callback)
protected Object	putIfAbsentInternal(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy, boolean withCompletionEvent, boolean async)
protected V	putSyncInternal(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy, boolean isGet)
void	removeAll()
protected void	removeAllInternal()
protected void	removeAllKeysInternal(Set<? extends K> keys, Collection<Data> dataKeys, long startNanos)
protected Object	removeAsyncInternal(K key, V oldValue, boolean hasOldValue, boolean withCompletionEvent, boolean async)
protected void	removeListenerLocally(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)
protected <T> InternalCompletableFuture<T>	replaceAndGetAsyncInternal(K key, V oldValue, V newValue, javax.cache.expiry.ExpiryPolicy expiryPolicy, boolean hasOldValue, boolean withCompletionEvent, boolean async)
protected <T> InternalCompletableFuture<T>	replaceAsyncInternal(K key, V oldValue, V newValue, javax.cache.expiry.ExpiryPolicy expiryPolicy, boolean hasOldValue, boolean withCompletionEvent, boolean async)
protected boolean	replaceSyncInternal(K key, V oldValue, V newValue, javax.cache.expiry.ExpiryPolicy expiryPolicy, boolean hasOldValue)
void	resetCacheManager() Reset cache manager of this cache proxy to null.
void	setCacheManager(HazelcastCacheManager cacheManager) Sets relevant HazelcastCacheManager to client/server.
protected boolean	setExpiryPolicyInternal(K key, javax.cache.expiry.ExpiryPolicy expiryPolicy)
void	setExpiryPolicyInternal(Set<? extends K> keys, javax.cache.expiry.ExpiryPolicy expiryPolicy)
protected void	setExpiryPolicyInternal(Set<? extends K> keys, javax.cache.expiry.ExpiryPolicy policy, Set<Data> serializedKeys)
protected void	updateCacheListenerConfigOnOtherNodes(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration, boolean isRegister)
protected ClientDelegatingFuture<V>	wrapPutAsyncFuture(K key, V value, Data keyData, Data valueData, ClientInvocationFuture invocationFuture, BiConsumer<V,Throwable> callback)

Methods inherited from class com.hazelcast.client.cache.impl.ClientCacheProxy

addPartitionLostListener, containsKey, deregisterCacheEntryListener, get, get, getAll, getAll, getAndPut, getAndPut, getAndPutAsync, getAndPutAsync, getAndRemove, getAndRemoveAsync, getAndReplace, getAndReplace, getAndReplaceAsync, getAndReplaceAsync, getAsync, getAsync, getConfiguration, getLocalCacheStatistics, invoke, invokeAll, iterator, iterator, iterator, loadAll, onLoadAll, put, put, putAll, putAll, putAsync, putAsync, putIfAbsent, putIfAbsent, putIfAbsentAsync, putIfAbsentAsync, readFromEventJournal, registerCacheEntryListener, registerCacheEntryListener, remove, remove, removeAll, removeAsync, removeAsync, removePartitionLostListener, replace, replace, replace, replace, replaceAsync, replaceAsync, replaceAsync, replaceAsync, setExpiryPolicy, setExpiryPolicy, size, subscribeToEventJournal, unwrap

Methods inherited from class com.hazelcast.client.impl.spi.ClientProxy

deregisterListener, destroy, destroyLocally, destroyRemotely, equals, getClient, getContext, getId, getName, getPartitionKey, getSerializationService, getServiceName, hashCode, invoke, invokeOnAddress, invokeOnPartition, invokeOnPartitionInterruptibly, onShutdown, registerListener, toData, toObject

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.cache.impl.CacheSyncListenerCompleter

countDownCompletionLatch

Methods inherited from interface com.hazelcast.cache.ICache

destroy

Methods inherited from interface javax.cache.Cache

getName

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface com.hazelcast.core.DistributedObject

getName, getPartitionKey, getServiceName

Field Detail

name

protected final String name

nameWithPrefix

protected final String nameWithPrefix

cacheConfig

protected final CacheConfig<K,V> cacheConfig

partitionCount

protected int partitionCount

Method Detail

getNearCache

public NearCache getNearCache()

onInitialize

protected void onInitialize()

Description copied from class: ClientProxy

Called when proxy is created. Overriding implementations can add initialization specific logic into this method like registering a listener, creating a cleanup task etc.

Overrides:

onInitialize in class ClientCacheProxy<K,V>

getSyncInternal

protected V getSyncInternal(Object key,
                            javax.cache.expiry.ExpiryPolicy expiryPolicy)

getAsyncInternal

protected InternalCompletableFuture<V> getAsyncInternal(Object key,
                                                        javax.cache.expiry.ExpiryPolicy expiryPolicy,
                                                        BiConsumer<V,Throwable> callback)

onPutSyncInternal

protected void onPutSyncInternal(K key,
                                 V value,
                                 Data keyData,
                                 Data valueData)

onPutIfAbsentSyncInternal

protected void onPutIfAbsentSyncInternal(K key,
                                         V value,
                                         Data keyData,
                                         Data valueData)

onPutIfAbsentAsyncInternal

protected void onPutIfAbsentAsyncInternal(K key,
                                          V value,
                                          Data keyData,
                                          Data valueData,
                                          ClientDelegatingFuture<Boolean> delegatingFuture,
                                          BiConsumer<Boolean,Throwable> callback)

wrapPutAsyncFuture

protected ClientDelegatingFuture<V> wrapPutAsyncFuture(K key,
                                                       V value,
                                                       Data keyData,
                                                       Data valueData,
                                                       ClientInvocationFuture invocationFuture,
                                                       BiConsumer<V,Throwable> callback)

onGetAndRemoveAsyncInternal

protected <T> void onGetAndRemoveAsyncInternal(K key,
                                               Data keyData,
                                               ClientDelegatingFuture<T> delegatingFuture,
                                               BiConsumer<T,Throwable> callback)

onReplaceInternalAsync

protected <T> void onReplaceInternalAsync(K key,
                                          V value,
                                          Data keyData,
                                          Data valueData,
                                          ClientDelegatingFuture<T> delegatingFuture,
                                          BiConsumer<T,Throwable> callback)

onReplaceAndGetAsync

protected <T> void onReplaceAndGetAsync(K key,
                                        V value,
                                        Data keyData,
                                        Data valueData,
                                        ClientDelegatingFuture<T> delegatingFuture,
                                        BiConsumer<T,Throwable> callback)

getAllInternal

protected void getAllInternal(Set<? extends K> keys,
                              Collection<Data> dataKeys,
                              javax.cache.expiry.ExpiryPolicy expiryPolicy,
                              List<Object> resultingKeyValuePairs,
                              long startNanos)

setExpiryPolicyInternal

public void setExpiryPolicyInternal(Set<? extends K> keys,
                                    javax.cache.expiry.ExpiryPolicy expiryPolicy)

setExpiryPolicyInternal

protected boolean setExpiryPolicyInternal(K key,
                                          javax.cache.expiry.ExpiryPolicy expiryPolicy)

putAllInternal

protected void putAllInternal(Map<? extends K,? extends V> map,
                              javax.cache.expiry.ExpiryPolicy expiryPolicy,
                              Map<Object,Data> keyMap,
                              List<Map.Entry<Data,Data>>[] entriesPerPartition,
                              long startNanos)

containsKeyInternal

protected boolean containsKeyInternal(Object key)

loadAllInternal

protected void loadAllInternal(Set<? extends K> keys,
                               List<Data> dataKeys,
                               boolean replaceExistingValues,
                               javax.cache.integration.CompletionListener completionListener)

removeAllKeysInternal

protected void removeAllKeysInternal(Set<? extends K> keys,
                                     Collection<Data> dataKeys,
                                     long startNanos)

onRemoveSyncInternal

public void onRemoveSyncInternal(Object key,
                                 Data keyData)

onRemoveAsyncInternal

protected void onRemoveAsyncInternal(Object key,
                                     Data keyData,
                                     ClientDelegatingFuture future,
                                     BiConsumer<Object,Throwable> callback)

removeAll

public void removeAll()

Specified by:

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

Overrides:

removeAll in class ClientCacheProxy<K,V>

clear

public void clear()

Specified by:

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

Overrides:

clear in class ClientCacheProxy<K,V>

invokeInternal

protected Object invokeInternal(Object key,
                                Data epData,
                                Object[] arguments)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

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

postDestroy

protected void postDestroy()

Description copied from class: ClientProxy

Called after proxy is destroyed.

addNearCacheInvalidationListener

public UUID addNearCacheInvalidationListener(EventHandler eventHandler)

getDistributedObjectName

protected String getDistributedObjectName()

Overrides:

getDistributedObjectName in class ClientProxy

preDestroy

protected boolean preDestroy()

Description copied from class: ClientProxy

Called before proxy is destroyed and determines whether destroy should be done.

Overrides:

preDestroy in class ClientProxy

Returns:

true if destroy should be done, otherwise false

isClosed

public boolean isClosed()

Specified by:

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

isDestroyed

public boolean isDestroyed()

Description copied from interface: ICache

Determines whether this Cache instance has been destroyed.

Specified by:

isDestroyed in interface ICache<K,V>

Returns:

true if this Cache instance is destroyed; false if it is still open.

open

public void open()

Description copied from interface: ICacheInternal

Opens cache if available (not destroyed). If cache is already open, does nothing.

Specified by:

open in interface ICacheInternal<K,V>

getPrefixedName

public String getPrefixedName()

Description copied from interface: PrefixedDistributedObject

Returns the unique prefixed name for this DistributedObject. The returned value will never be null.

Specified by:

getPrefixedName in interface PrefixedDistributedObject

Returns:

the unique prefixed name for this object.

invoke

protected <T> T invoke(ClientMessage clientMessage)

Overrides:

invoke in class ClientProxy

countDownCompletionLatch

public void countDownCompletionLatch(int countDownLatchId)

Specified by:

countDownCompletionLatch in interface CacheSyncListenerCompleter

getCacheManager

public javax.cache.CacheManager getCacheManager()

Specified by:

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

setCacheManager

public void setCacheManager(HazelcastCacheManager cacheManager)

Description copied from interface: ICacheInternal

Sets relevant HazelcastCacheManager to client/server.

Specified by:

setCacheManager in interface ICacheInternal<K,V>

Parameters:

cacheManager - client or server HazelcastCacheManager

resetCacheManager

public void resetCacheManager()

Description copied from interface: ICacheInternal

Reset cache manager of this cache proxy to null. Whenever a Cache is not managed any more (for example after Cache.close() has been called), its CacheManager should be reset.

Specified by:

resetCacheManager in interface ICacheInternal<K,V>

onDestroy

protected void onDestroy()

Description copied from class: ClientProxy

Called before proxy is destroyed. Overriding implementations should clean/release resources created during initialization.

Overrides:

onDestroy in class ClientProxy

ensureOpen

protected void ensureOpen()

injectDependencies

protected void injectDependencies(Object obj)

nowInNanosOrDefault

protected long nowInNanosOrDefault()

invoke

protected ClientInvocationFuture invoke(ClientMessage req,
                                        int partitionId,
                                        int completionId)

invoke

protected ClientInvocationFuture invoke(ClientMessage req,
                                        Data keyData,
                                        int completionId)

getAndRemoveAsyncInternal

protected <T> InternalCompletableFuture<T> getAndRemoveAsyncInternal(K key)

getAndRemoveSyncInternal

protected <T> ClientDelegatingFuture<T> getAndRemoveSyncInternal(K key)

removeAsyncInternal

protected Object removeAsyncInternal(K key,
                                     V oldValue,
                                     boolean hasOldValue,
                                     boolean withCompletionEvent,
                                     boolean async)

replaceSyncInternal

protected boolean replaceSyncInternal(K key,
                                      V oldValue,
                                      V newValue,
                                      javax.cache.expiry.ExpiryPolicy expiryPolicy,
                                      boolean hasOldValue)

replaceAsyncInternal

protected <T> InternalCompletableFuture<T> replaceAsyncInternal(K key,
                                                                V oldValue,
                                                                V newValue,
                                                                javax.cache.expiry.ExpiryPolicy expiryPolicy,
                                                                boolean hasOldValue,
                                                                boolean withCompletionEvent,
                                                                boolean async)

replaceAndGetAsyncInternal

protected <T> InternalCompletableFuture<T> replaceAndGetAsyncInternal(K key,
                                                                      V oldValue,
                                                                      V newValue,
                                                                      javax.cache.expiry.ExpiryPolicy expiryPolicy,
                                                                      boolean hasOldValue,
                                                                      boolean withCompletionEvent,
                                                                      boolean async)

putSyncInternal

protected V putSyncInternal(K key,
                            V value,
                            javax.cache.expiry.ExpiryPolicy expiryPolicy,
                            boolean isGet)

putAsyncInternal

protected ClientDelegatingFuture putAsyncInternal(K key,
                                                  V value,
                                                  javax.cache.expiry.ExpiryPolicy expiryPolicy,
                                                  boolean isGet,
                                                  boolean withCompletionEvent,
                                                  BiConsumer<V,Throwable> callback)

newStatsCallbackOrNull

protected BiConsumer<V,Throwable> newStatsCallbackOrNull(boolean isGet)

putIfAbsentInternal

protected Object putIfAbsentInternal(K key,
                                     V value,
                                     javax.cache.expiry.ExpiryPolicy expiryPolicy,
                                     boolean withCompletionEvent,
                                     boolean async)

removeAllInternal

protected void removeAllInternal()

clearInternal

protected void clearInternal()

addListenerLocally

protected void addListenerLocally(UUID regId,
                                  javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration,
                                  CacheEventListenerAdaptor<K,V> adaptor)

removeListenerLocally

protected void removeListenerLocally(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)

getListenerIdLocal

protected UUID getListenerIdLocal(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration)

setExpiryPolicyInternal

protected void setExpiryPolicyInternal(Set<? extends K> keys,
                                       javax.cache.expiry.ExpiryPolicy policy,
                                       Set<Data> serializedKeys)

updateCacheListenerConfigOnOtherNodes

protected void updateCacheListenerConfigOnOtherNodes(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration,
                                                     boolean isRegister)

getLogger

protected ILogger getLogger()