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

Modifier and Type	Method and Description
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 for a future time. Imagine you are implementing this for dirty records: if mapStore.storeAll throws an exception, you might want to reschedule the failed records.

Parameters:

scheduler - the EntryTaskScheduler

entries - the entries (key and value) to process