Package 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 java.lang.Object
implements DistributedProcessHandler.ProcessExecutionAnalysisContext

Field Summary

Fields

Modifier and Type	Field	Description
protected DistributedProcessModel	process

Constructor Summary

Constructors

Constructor	Description
SimpleAbstractTurnContext(DistributedProcessModel process)

Method Summary

Modifier and Type	Method	Description
protected java.lang.String	getNextExecutionId()
java.util.stream.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 java.util.stream.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 java.lang.String getNextExecutionId()