com.hazelcast.queue.impl

Class QueueEvictionProcessor

java.lang.Object

com.hazelcast.queue.impl.QueueEvictionProcessor

All Implemented Interfaces:

ScheduledEntryProcessor<String,Void>

public class QueueEvictionProcessor
extends Object
implements ScheduledEntryProcessor<String,Void>

Eviction Processor for the Queue.

Constructor Summary

Constructors

Constructor and Description
QueueEvictionProcessor(NodeEngine nodeEngine, QueueService service)

Method Summary

Methods

Modifier and Type	Method and Description
void	process(EntryTaskScheduler<String,Void> scheduler, Collection<ScheduledEntry<String,Void>> entries) Processes all entries.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueEvictionProcessor

public QueueEvictionProcessor(NodeEngine nodeEngine,
                      QueueService service)

Method Detail

process

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