com.hazelcast.map.impl.nearcache

Class NonStopInvalidator

java.lang.Object

com.hazelcast.map.impl.nearcache.AbstractNearCacheInvalidator

com.hazelcast.map.impl.nearcache.NonStopInvalidator

All Implemented Interfaces:

NearCacheInvalidator

public class NonStopInvalidator
extends AbstractNearCacheInvalidator

Sends invalidations to near-caches immediately.

Field Summary

Fields inherited from class com.hazelcast.map.impl.nearcache.AbstractNearCacheInvalidator

clusterService, eventService, mapServiceContext, nearCacheProvider, nodeEngine, operationService

Constructor Summary

Constructors

Constructor and Description
NonStopInvalidator(MapServiceContext mapServiceContext, NearCacheProvider nearCacheProvider)

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy(String mapName) Removes supplied maps invalidation queue and flushes its content.
void	invalidate(String mapName, Data key, String sourceUuid) Invalidates local and remote near-caches.
void	invalidate(String mapName, List<Data> keys, String sourceUuid) Invalidates local and remote near-caches.
protected void	invalidateClient(String mapName, Data key, List<Data> keys, String sourceUuid)
protected void	invalidateMember(String mapName, Data key, List<Data> keys, String sourceUuid)
void	reset() Resets this invalidator back to its initial state.
void	sendClientNearCacheClearEvent(String mapName, String sourceUuid) Send clear event to client-side near-cache invalidation listeners.
void	shutdown() Shuts down this invalidator and releases used resources.

Methods inherited from class com.hazelcast.map.impl.nearcache.AbstractNearCacheInvalidator

clearLocalNearCache, createSingleOrBatchInvalidationOperation, getOrderKey, hasInvalidationListener, invalidateLocal, isMemberNearCacheInvalidationEnabled, toHeapData

Methods inherited from class java.lang.Object

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

Constructor Detail

NonStopInvalidator

public NonStopInvalidator(MapServiceContext mapServiceContext,
                  NearCacheProvider nearCacheProvider)

Method Detail

invalidate

public void invalidate(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 members or clients.

Parameters:

mapName - name of the map.

key - key of the entry to be removed from near-cache.

sourceUuid - caller uuid

invalidate

public void invalidate(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 members or clients.

Parameters:

mapName - name of the map.

keys - keys of the entries to be removed from near-cache.

sourceUuid - caller uuid

sendClientNearCacheClearEvent

public void sendClientNearCacheClearEvent(String mapName,
                                 String sourceUuid)

Description copied from interface: NearCacheInvalidator

Send clear event to client-side near-cache invalidation listeners.

Parameters:

mapName - name of the map.

sourceUuid - caller uuid

destroy

public void destroy(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)

Parameters:

mapName - name of the map.

See Also:

MapRemoteService.destroyDistributedObject(String)

reset

public void reset()

Description copied from interface: NearCacheInvalidator

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

See Also:

ManagedService#reset()}

shutdown

public void shutdown()

Description copied from interface: NearCacheInvalidator

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

See Also:

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

invalidateClient

protected void invalidateClient(String mapName,
                    Data key,
                    List<Data> keys,
                    String sourceUuid)

invalidateMember

protected void invalidateMember(String mapName,
                    Data key,
                    List<Data> keys,
                    String sourceUuid)