com.hazelcast.map.impl.nearcache.invalidation

Class Invalidator

java.lang.Object

com.hazelcast.map.impl.nearcache.invalidation.Invalidator

Direct Known Subclasses:

BatchInvalidator, NonStopInvalidator

public abstract class Invalidator
extends Object

Contains common functionality of a Invalidator

Field Summary

Fields

Modifier and Type	Field and Description
protected EventService	eventService
protected ILogger	logger
protected MapServiceContext	mapServiceContext
protected MetaDataGenerator	metaDataGenerator
protected NodeEngine	nodeEngine
protected int	partitionCount
protected IPartitionService	partitionService
protected SerializationService	serializationService

Constructor Summary

Constructors

Constructor and Description
Invalidator(MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
protected boolean	canSendInvalidation(EventFilter filter)
void	destroy(String mapName, String sourceUuid) Removes supplied maps invalidation queue and flushes its content.
MetaDataGenerator	getMetaDataGenerator()
protected int	getPartitionId(Data o)
protected int	getPartitionId(Object o)
void	invalidateAllKeys(String mapName, String sourceUuid) Invalidates all keys from near-caches of supplied map name.
protected abstract void	invalidateInternal(Invalidation invalidation, int orderKey)
void	invalidateKey(Data key, String mapName, String sourceUuid) Invalidates supplied key from near-caches of supplied map name.
protected Invalidation	newClearInvalidation(String mapName, String sourceUuid)
protected Invalidation	newKeyInvalidation(Data key, String mapName, String sourceUuid)
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

Field Detail

logger

protected final ILogger logger

partitionCount

protected final int partitionCount

mapServiceContext

protected final MapServiceContext mapServiceContext

nodeEngine

protected final NodeEngine nodeEngine

eventService

protected final EventService eventService

serializationService

protected final SerializationService serializationService

metaDataGenerator

protected final MetaDataGenerator metaDataGenerator

partitionService

protected final IPartitionService partitionService

Constructor Detail

Invalidator

public Invalidator(MapServiceContext mapServiceContext)

Method Detail

invalidateKey

public final void invalidateKey(Data key,
                                String mapName,
                                String sourceUuid)

Invalidates supplied key from near-caches of supplied map name.

Parameters:

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

mapName - name of the map to be invalidated

invalidateAllKeys

public final void invalidateAllKeys(String mapName,
                                    String sourceUuid)

Invalidates all keys from near-caches of supplied map name.

Parameters:

mapName - name of the map to be cleared

invalidateInternal

protected abstract void invalidateInternal(Invalidation invalidation,
                                           int orderKey)

getMetaDataGenerator

public MetaDataGenerator getMetaDataGenerator()

newKeyInvalidation

protected final Invalidation newKeyInvalidation(Data key,
                                                String mapName,
                                                String sourceUuid)

newClearInvalidation

protected final Invalidation newClearInvalidation(String mapName,
                                                  String sourceUuid)

getPartitionId

protected final int getPartitionId(Data o)

getPartitionId

protected final int getPartitionId(Object o)

canSendInvalidation

protected final boolean canSendInvalidation(EventFilter filter)

destroy

public void destroy(String mapName,
                    String sourceUuid)

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()

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

See Also:

ManagedService.reset()

shutdown

public void shutdown()

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

See Also:

ManagedService.shutdown(boolean)