public class NonStopInvalidator extends AbstractNearCacheInvalidator
clusterService, eventService, mapServiceContext, nearCacheProvider, nodeEngine, operationService
Constructor and Description |
---|
NonStopInvalidator(MapServiceContext mapServiceContext,
NearCacheProvider nearCacheProvider) |
Modifier and Type | Method and Description |
---|---|
void |
clear(String mapName,
boolean owner,
String sourceUuid)
Clears local and remote near-caches.
|
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 |
shutdown()
Shuts down this invalidator and releases used resources.
|
clearLocal, createSingleOrBatchInvalidationOperation, getOrderKey, hasInvalidationListener, invalidateLocal, isMemberNearCacheInvalidationEnabled, toHeapData
public NonStopInvalidator(MapServiceContext mapServiceContext, NearCacheProvider nearCacheProvider)
public void invalidate(String mapName, Data key, String sourceUuid)
NearCacheInvalidator
mapName
- name of the map.key
- key of the entry to be removed from near-cache.sourceUuid
- caller uuidpublic void invalidate(String mapName, List<Data> keys, String sourceUuid)
NearCacheInvalidator
mapName
- name of the map.keys
- keys of the entries to be removed from near-cache.sourceUuid
- caller uuidpublic void clear(String mapName, boolean owner, String sourceUuid)
NearCacheInvalidator
mapName
- name of the map.owner
- true
if this method is called from partition owner, otherwise false
.sourceUuid
- caller uuidpublic void destroy(String mapName)
NearCacheInvalidator
MapRemoteService.destroyDistributedObject(String)
mapName
- name of the map.MapRemoteService.destroyDistributedObject(String)
public void reset()
NearCacheInvalidator
ManagedService.reset()
ManagedService#reset()}
public void shutdown()
NearCacheInvalidator
ManagedService.shutdown(boolean)
com.hazelcast.spi.ManagedService#shutdown(boolean)}
protected void invalidateClient(String mapName, Data key, List<Data> keys, String sourceUuid)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.