Class ProcessManagerClientImpl

java.lang.Object

org.chenile.orchestrator.delegate.ProcessManagerClientImpl

All Implemented Interfaces:

ProcessManagerClient

public class ProcessManagerClientImpl
extends Object
implements ProcessManagerClient

Field Summary

Fields

Modifier and Type	Field	Description
private final org.slf4j.Logger	logger
private ProcessManager	processServiceProxy

Constructor Summary

Constructors

Constructor	Description
ProcessManagerClientImpl()

Method Summary

Modifier and Type	Method	Description
Process	aggregationDone(String id, AggregationDonePayload payload)
Process	aggregationDoneWithErrors(String id, DoneWithErrorsPayload payload)
private Process	callCreate(Process process)
Process	doneSuccessfully(String id, DoneSuccessfullyPayload payload)
Process	doneWithErrors(String id, DoneWithErrorsPayload payload)
List<Process>	getSubProcesses(String id, boolean recursive)
Process	process(String id, String event, Object payload)
Process	splitDone(String id, StartProcessingPayload payload)
Process	splitDoneWithErrors(String id, DoneWithErrorsPayload payload)
Process	splitPartiallyDone(String id, StartProcessingPayload payload)
Process	start(Process process)
Process	statusUpdate(String id, StatusUpdatePayload payload)

Methods inherited from class Object

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

Field Details

logger

private final org.slf4j.Logger logger

processServiceProxy

@Autowired
@Qualifier("processServiceProxy")
private ProcessManager processServiceProxy

Constructor Details

ProcessManagerClientImpl

public ProcessManagerClientImpl()

Method Details

start

public Process start(Process process)

Specified by:

start in interface ProcessManagerClient

splitPartiallyDone

public Process splitPartiallyDone(String id,
 StartProcessingPayload payload)

Specified by:

splitPartiallyDone in interface ProcessManagerClient

splitDone

public Process splitDone(String id,
 StartProcessingPayload payload)

Specified by:

splitDone in interface ProcessManagerClient

aggregationDone

public Process aggregationDone(String id,
 AggregationDonePayload payload)

Specified by:

aggregationDone in interface ProcessManagerClient

statusUpdate

public Process statusUpdate(String id,
 StatusUpdatePayload payload)

Specified by:

statusUpdate in interface ProcessManagerClient

doneSuccessfully

public Process doneSuccessfully(String id,
 DoneSuccessfullyPayload payload)

Specified by:

doneSuccessfully in interface ProcessManagerClient

doneWithErrors

public Process doneWithErrors(String id,
 DoneWithErrorsPayload payload)

Specified by:

doneWithErrors in interface ProcessManagerClient

splitDoneWithErrors

public Process splitDoneWithErrors(String id,
 DoneWithErrorsPayload payload)

Specified by:

splitDoneWithErrors in interface ProcessManagerClient

aggregationDoneWithErrors

public Process aggregationDoneWithErrors(String id,
 DoneWithErrorsPayload payload)

Specified by:

aggregationDoneWithErrors in interface ProcessManagerClient

callCreate

private Process callCreate(Process process)

process

public Process process(String id,
 String event,
 Object payload)

Specified by:

process in interface ProcessManagerClient

getSubProcesses

public List<Process> getSubProcesses(String id,
 boolean recursive)

Specified by:

getSubProcesses in interface ProcessManagerClient