com.hazelcast.map.impl.nearcache

Class NearCacheInvalidatorImpl

java.lang.Object

com.hazelcast.map.impl.nearcache.NearCacheInvalidatorImpl

All Implemented Interfaces:

NearCacheInvalidator

public class NearCacheInvalidatorImpl
extends Object
implements NearCacheInvalidator

Default implementation of NearCacheInvalidator

See Also:

NearCacheInvalidator

Method Summary

Methods

Modifier and Type	Method and Description
void	accumulateOrSendBatchInvalidation(String mapName, Data key)
void	clearLocalNearCache(String mapName, String sourceUuid) Only clears local near-cache.
void	clearNearCaches(String mapName, boolean owner, String sourceUuid) Clears local and remote near-caches.
void	flushAndRemoveInvalidationQueue(String mapName) Removes supplied maps invalidation queue and flushes its content.
static Object	getOrderKey(String mapName, Invalidation invalidation)
protected boolean	hasInvalidationListener(String mapName)
void	invalidateLocalNearCache(String mapName, Collection<Data> keys) Only invalidates local near-cache on a node.
void	invalidateLocalNearCache(String mapName, Data key) Only invalidates local near-cache on a node.
void	invalidateNearCaches(String mapName, Data key, String sourceUuid) Invalidates local and remote near-caches.
void	invalidateNearCaches(String mapName, List<Data> keys, String sourceUuid) Invalidates local and remote near-caches.
void	reset() Resets this invalidator back to its initial state.
void	shutdown() Shuts down this invalidator and releases used resources.

Methods inherited from class java.lang.Object

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

Method Detail

invalidateLocalNearCache

public void invalidateLocalNearCache(String mapName,
                            Data key)

Description copied from interface: NearCacheInvalidator

Only invalidates local near-cache on a node.

Specified by:

invalidateLocalNearCache in interface NearCacheInvalidator

Parameters:

mapName - name of the map.

key - key of the entry to be removed.

invalidateLocalNearCache

public void invalidateLocalNearCache(String mapName,
                            Collection<Data> keys)

Description copied from interface: NearCacheInvalidator

Only invalidates local near-cache on a node.

Specified by:

invalidateLocalNearCache in interface NearCacheInvalidator

Parameters:

mapName - name of the map.

keys - keys of the entries to be removed.

clearLocalNearCache

public void clearLocalNearCache(String mapName,
                       String sourceUuid)

Description copied from interface: NearCacheInvalidator

Only clears local near-cache.

Specified by:

clearLocalNearCache in interface NearCacheInvalidator

Parameters:

mapName - name of the map.

sourceUuid - caller uuid

clearNearCaches

public void clearNearCaches(String mapName,
                   boolean owner,
                   String sourceUuid)

Description copied from interface: NearCacheInvalidator

Clears local and remote near-caches. Local near-caches are node local, remote near-caches can be exist on remote nodes or clients.

Specified by:

clearNearCaches in interface NearCacheInvalidator

Parameters:

mapName - name of the map.

owner - true if this method is called from partition owner, otherwise false.

sourceUuid - caller uuid

invalidateNearCaches

public void invalidateNearCaches(String mapName,
                        Data key,
                        String sourceUuid)

Description copied from interface: NearCacheInvalidator

Invalidates local and remote near-caches. Local near-caches are node local, remote near-caches can be exist on remote nodes or clients.

Specified by:

invalidateNearCaches in interface NearCacheInvalidator

Parameters:

mapName - name of the map.

key - key of the entry to be removed.

sourceUuid - caller uuid

invalidateNearCaches

public void invalidateNearCaches(String mapName,
                        List<Data> keys,
                        String sourceUuid)

Description copied from interface: NearCacheInvalidator

Invalidates local and remote near-caches. Local near-caches are node local, remote near-caches can be exist on remote nodes or clients.

Specified by:

invalidateNearCaches in interface NearCacheInvalidator

Parameters:

mapName - name of the map.

keys - keys of the entries to be removed.

sourceUuid - caller uuid

flushAndRemoveInvalidationQueue

public void flushAndRemoveInvalidationQueue(String mapName)

Description copied from interface: NearCacheInvalidator

Removes supplied maps invalidation queue and flushes its content. This method is called when removing a near-cache with MapRemoteService.destroyDistributedObject(String)

Specified by:

flushAndRemoveInvalidationQueue in interface NearCacheInvalidator

Parameters:

mapName - name of the map.

See Also:

MapRemoteService.destroyDistributedObject(String)

shutdown

public void shutdown()

Description copied from interface: NearCacheInvalidator

Shuts down this invalidator and releases used resources. Aimed to call with ManagedService.shutdown(boolean)

Specified by:

shutdown in interface NearCacheInvalidator

See Also:

com.hazelcast.spi.ManagedService#shutdown(boolean)}

reset

public void reset()

Description copied from interface: NearCacheInvalidator

Resets this invalidator back to its initial state. Aimed to call with ManagedService.reset()

Specified by:

reset in interface NearCacheInvalidator

See Also:

ManagedService#reset()}

accumulateOrSendBatchInvalidation

public void accumulateOrSendBatchInvalidation(String mapName,
                                     Data key)

hasInvalidationListener

protected boolean hasInvalidationListener(String mapName)

getOrderKey

public static Object getOrderKey(String mapName,
                 Invalidation invalidation)