at.molindo.esi4j.chain

Interface Esi4JTaskProcessor

All Known Implementing Classes:

AbstractTaskProcessor, DefaultTaskProcessor, QueuedTaskProcessor

public interface Esi4JTaskProcessor

processes Esi4JEntityTasks against an Esi4JIndex. For instance, a processor might be synchronous or asynchronous.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
<T> T	execute(SerializableEsi4JOperation<T> operation) executes operation after currently submitted tasks and before newly submitted tasks
Esi4JIndex	getIndex()
void	processTasks(Esi4JEntityTask[] tasks)
void	processTasks(Iterable<Esi4JEntityTask[]> tasks) same as calling processTasks(Esi4JEntityTask[]) multiple times, but might have better performance

Method Detail

getIndex

Esi4JIndex getIndex()

Returns:

an index, must never change

processTasks

void processTasks(Esi4JEntityTask[] tasks)

Parameters:

tasks - an array of Esi4JEntityTask, may contain multiple tasks for the same entity or null

processTasks

void processTasks(Iterable<Esi4JEntityTask[]> tasks)

same as calling processTasks(Esi4JEntityTask[]) multiple times, but might have better performance

execute

<T> T execute(SerializableEsi4JOperation<T> operation)

executes operation after currently submitted tasks and before newly submitted tasks

close

void close()