com.hazelcast.util.scheduler
Interface ScheduledEntryProcessor<K,V>

Type Parameters:

K - key type of related entries

V - value type of related entries

All Known Implementing Classes:

LockEvictionProcessor, QueueEvictionProcessor, ReplicatedMapEvictionProcessor

public interface ScheduledEntryProcessor<K,V>

Method Summary

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

Method Detail

process

void process(EntryTaskScheduler<K,V> scheduler,
             Collection<ScheduledEntry<K,V>> entries)

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.

Parameters:

scheduler -

entries -