public final class ExpirationManager extends Object implements LifecycleListener, PartitionLostListener
3.3
and ICache since
3.11
Constructor and Description |
---|
ExpirationManager(ClearExpiredRecordsTask task,
NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
protected HazelcastInstance |
getHazelcastInstance() |
ClearExpiredRecordsTask |
getTask() |
void |
onClusterStateChange(ClusterState newState) |
void |
onShutdown()
Called upon shutdown of
MapService |
void |
partitionLost(PartitionLostEvent event)
Invoked when a partition loses its owner and all backups.
|
void |
scheduleExpirationTask()
Starts scheduling of the task that clears expired entries.
|
void |
stateChanged(LifecycleEvent event)
Called when instance's state changes.
|
public ExpirationManager(ClearExpiredRecordsTask task, NodeEngine nodeEngine)
protected HazelcastInstance getHazelcastInstance()
public void scheduleExpirationTask()
public void stateChanged(LifecycleEvent event)
LifecycleListener
stateChanged
in interface LifecycleListener
event
- the Lifecycle eventpublic void partitionLost(PartitionLostEvent event)
PartitionLostListener
partitionLost
in interface PartitionLostListener
event
- the event that contains the partition ID and the backup count that has been lostpublic void onClusterStateChange(ClusterState newState)
public void onShutdown()
MapService
public ClearExpiredRecordsTask getTask()
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.