Class ExecutorBase<Input,Output>

java.lang.Object

org.chenile.orchestrator.process.utils.base.ExecutorBase<Input,Output>

All Implemented Interfaces:

IWorker<Input>

public abstract class ExecutorBase<Input,Output>
extends Object
implements IWorker<Input>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) org.slf4j.Logger	logger
protected final ObjectMapper	objectMapper
(package private) ProcessManagerClient	processManagerClient

Constructor Summary

Constructors

Constructor	Description
ExecutorBase()

Method Summary

Modifier and Type	Method	Description
protected abstract Output	doStart(WorkerDto workerDto, Input input)	Convert input to output.
protected void	progressUpdate(String processId, int percent)
final void	start(WorkerDto workerDto, Input input)

Methods inherited from class Object

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

Field Details

logger

org.slf4j.Logger logger

processManagerClient

@Autowired
ProcessManagerClient processManagerClient

objectMapper

protected final ObjectMapper objectMapper

Constructor Details

ExecutorBase

public ExecutorBase()

Method Details

start

public final void start(WorkerDto workerDto,
 Input input)

Specified by:

start in interface IWorker<Input>

doStart

protected abstract Output doStart(WorkerDto workerDto,
 Input input)

Convert input to output. Throw an exception in cases of errors. Exception must extend ErrorNumException
Call progressUpdate(String,int) progressUpdate} in case you want to update progress.

Parameters:

workerDto - - The Worker DTO to work with

input - - Converted into a Java object from JSON.

Returns:

the output that will be sent back to the Process.

progressUpdate

protected void progressUpdate(String processId,
 int percent)