de.hybris.platform.processing.distributed.simple.context

Class SimpleAbstractTurnContext

java.lang.Object

de.hybris.platform.processing.distributed.simple.context.SimpleAbstractTurnContext

All Implemented Interfaces:

DistributedProcessHandler.ProcessExecutionAnalysisContext

Direct Known Subclasses:

SimpleNextTurnContext, SimpleProcessFailedContext, SimpleProcessFinishedSuccessfullyContext

public abstract class SimpleAbstractTurnContext
extends Object
implements DistributedProcessHandler.ProcessExecutionAnalysisContext

Field Summary

Fields

Modifier and Type	Field and Description
protected DistributedProcessModel	process

Constructor Summary

Constructors

Constructor and Description
SimpleAbstractTurnContext(DistributedProcessModel process)

Method Summary

Modifier and Type	Method and Description
protected String	getNextExecutionId()
Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>>	nextExecutionInputBatches()
DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel>	prepareProcessForNextExecution()

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHandler.ProcessExecutionAnalysisContext

processFailed, processSucceeded

Field Detail

process

protected final DistributedProcessModel process

Constructor Detail

SimpleAbstractTurnContext

public SimpleAbstractTurnContext(DistributedProcessModel process)

Method Detail

nextExecutionInputBatches

public Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>> nextExecutionInputBatches()

Specified by:

nextExecutionInputBatches in interface DistributedProcessHandler.ProcessExecutionAnalysisContext

prepareProcessForNextExecution

public DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel> prepareProcessForNextExecution()

Specified by:

prepareProcessForNextExecution in interface DistributedProcessHandler.ProcessExecutionAnalysisContext

getNextExecutionId

protected String getNextExecutionId()