com.hazelcast.replicatedmap.impl
Class ReplicatedMapEvictionProcessor

java.lang.Object
  com.hazelcast.replicatedmap.impl.ReplicatedMapEvictionProcessor

All Implemented Interfaces:

ScheduledEntryProcessor<Object,Object>

public class ReplicatedMapEvictionProcessor
extends Object
implements ScheduledEntryProcessor<Object,Object>

Actual eviction processor implementation to remove values to evict values from the replicated map

Constructor Summary

ReplicatedMapEvictionProcessor(NodeEngine nodeEngine, ReplicatedMapService replicatedMapService, String mapName)

Method Summary

void	process(EntryTaskScheduler<Object,Object> scheduler, Collection<ScheduledEntry<Object,Object>> entries) Processes all entries.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatedMapEvictionProcessor

public ReplicatedMapEvictionProcessor(NodeEngine nodeEngine,
                                      ReplicatedMapService replicatedMapService,
                                      String mapName)

Method Detail

process

public void process(EntryTaskScheduler<Object,Object> scheduler,
                    Collection<ScheduledEntry<Object,Object>> entries)

Description copied from interface: ScheduledEntryProcessor

Processes all entries. Implementation has to handle the failures and can possibly reschedule it for a future time. Imagine you are implementing this for a dirty records. If mapStore.storeAll throws exception, you might want to reschedule the failed records.

Specified by:

process in interface ScheduledEntryProcessor<Object,Object>