com.hazelcast.map

Class MapStoreDeleteProcessor

java.lang.Object

com.hazelcast.map.MapStoreDeleteProcessor

All Implemented Interfaces:

ScheduledEntryProcessor<Data,Object>

public class MapStoreDeleteProcessor
extends Object
implements ScheduledEntryProcessor<Data,Object>

Constructor Summary

Constructors

Constructor and Description
MapStoreDeleteProcessor(MapContainer mapContainer, MapService mapService)

Method Summary

Modifier and Type	Method and Description
void	process(EntryTaskScheduler<Data,Object> scheduler, Collection<ScheduledEntry<Data,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

MapStoreDeleteProcessor

public MapStoreDeleteProcessor(MapContainer mapContainer,
                               MapService mapService)

Method Detail

process

public void process(EntryTaskScheduler<Data,Object> scheduler,
                    Collection<ScheduledEntry<Data,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<Data,Object>