com.hazelcast.map.impl.nearcache.invalidation

Class BatchInvalidator

java.lang.Object

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

com.hazelcast.map.impl.nearcache.invalidation.BatchInvalidator

public class BatchInvalidator
extends Invalidator

Sends invalidations to Near Cache in batches.

Field Summary

Fields inherited from class com.hazelcast.map.impl.nearcache.invalidation.Invalidator

eventService, logger, mapServiceContext, metaDataGenerator, nodeEngine, partitionCount, partitionService, serializationService

Constructor Summary

Constructors

Constructor and Description
BatchInvalidator(MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
void	destroy(String mapName, String sourceUuid) Removes supplied maps invalidation queue and flushes its content.
protected void	invalidateInternal(Invalidation invalidation, int orderKey)
void	reset() Resets this invalidator back to its initial state.
void	shutdown() Shuts down this invalidator and releases used resources.

Methods inherited from class com.hazelcast.map.impl.nearcache.invalidation.Invalidator

canSendInvalidation, getMetaDataGenerator, getPartitionId, getPartitionId, invalidateAllKeys, invalidateKey, newClearInvalidation, newKeyInvalidation

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchInvalidator

public BatchInvalidator(MapServiceContext mapServiceContext)

Method Detail

invalidateInternal

protected void invalidateInternal(Invalidation invalidation,
                                  int orderKey)

Specified by:

invalidateInternal in class Invalidator

destroy

public void destroy(String mapName,
                    String sourceUuid)

Description copied from class: Invalidator

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

Overrides:

destroy in class Invalidator

Parameters:

mapName - name of the map.

See Also:

MapRemoteService.destroyDistributedObject(String)

shutdown

public void shutdown()

Description copied from class: Invalidator

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

Overrides:

shutdown in class Invalidator

See Also:

ManagedService.shutdown(boolean)

reset

public void reset()

Description copied from class: Invalidator

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

Overrides:

reset in class Invalidator

See Also:

ManagedService.reset()