ambit2.base.interfaces

Interface IBatchProcessor<Target,ItemInput,Result>

All Known Implementing Classes:

BatchProcessor

public interface IBatchProcessor<Target,ItemInput,Result>

Method Summary

Modifier and Type	Method and Description
void	afterProcessing(Target target, Iterator<ItemInput> iterator)
void	beforeProcessing(Target target)
void	cancel()
Iterator<ItemInput>	getIterator(Target target)
net.idea.modbcum.i.processors.ProcessorsChain<ItemInput,Result,net.idea.modbcum.i.processors.IProcessor>	getProcessorChain()
Result	getResult(Target target)
long	getTimeout()
void	onError(ItemInput input, Object output, Result result, Exception x)
void	onItemProcessed(ItemInput input, Object output, Result result)
void	onItemRead(ItemInput input, Result result)
void	setProcessorChain(net.idea.modbcum.i.processors.ProcessorsChain<ItemInput,Result,net.idea.modbcum.i.processors.IProcessor> processor)
void	setTimeout(long timeout)

Method Detail

getProcessorChain

net.idea.modbcum.i.processors.ProcessorsChain<ItemInput,Result,net.idea.modbcum.i.processors.IProcessor> getProcessorChain()

setProcessorChain

void setProcessorChain(net.idea.modbcum.i.processors.ProcessorsChain<ItemInput,Result,net.idea.modbcum.i.processors.IProcessor> processor)

getIterator

Iterator<ItemInput> getIterator(Target target)
                         throws net.idea.modbcum.i.exceptions.AmbitException

Throws:

net.idea.modbcum.i.exceptions.AmbitException

beforeProcessing

void beforeProcessing(Target target)
               throws net.idea.modbcum.i.exceptions.AmbitException

Throws:

net.idea.modbcum.i.exceptions.AmbitException

afterProcessing

void afterProcessing(Target target,
                     Iterator<ItemInput> iterator)
              throws net.idea.modbcum.i.exceptions.AmbitException

Throws:

net.idea.modbcum.i.exceptions.AmbitException

getResult

Result getResult(Target target)

onError

void onError(ItemInput input,
             Object output,
             Result result,
             Exception x)

onItemRead

void onItemRead(ItemInput input,
                Result result)

onItemProcessed

void onItemProcessed(ItemInput input,
                     Object output,
                     Result result)

getTimeout

long getTimeout()

setTimeout

void setTimeout(long timeout)

cancel

void cancel()