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

Class SimpleNextTurnContext

java.lang.Object

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

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

All Implemented Interfaces:

DistributedProcessHandler.ProcessExecutionAnalysisContext

public class SimpleNextTurnContext
extends SimpleAbstractTurnContext

Field Summary

Fields

Modifier and Type	Field and Description
protected ModelService	modelService

Fields inherited from class de.hybris.platform.processing.distributed.simple.context.SimpleAbstractTurnContext

process

Constructor Summary

Constructors

Constructor and Description
SimpleNextTurnContext(DistributedProcessModel process, java.lang.String previousExecutionId, ModelService modelService, FlexibleSearchService flexibleSearchService)

Method Summary

Modifier and Type	Method and Description
protected DistributedProcessHandler.ModelWithDependencies<BatchModel>	createInputBatch(SimpleBatchModel _inputBatch)
java.util.stream.Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>>	nextExecutionInputBatches()
boolean	processFailed()
boolean	processSucceeded()

Methods inherited from class de.hybris.platform.processing.distributed.simple.context.SimpleAbstractTurnContext

getNextExecutionId, prepareProcessForNextExecution

Methods inherited from class java.lang.Object

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

Field Detail

modelService

protected final ModelService modelService

Constructor Detail

SimpleNextTurnContext

public SimpleNextTurnContext(DistributedProcessModel process,
                             java.lang.String previousExecutionId,
                             ModelService modelService,
                             FlexibleSearchService flexibleSearchService)

Method Detail

processFailed

public boolean processFailed()

processSucceeded

public boolean processSucceeded()

nextExecutionInputBatches

public java.util.stream.Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>> nextExecutionInputBatches()

Specified by:

nextExecutionInputBatches in interface DistributedProcessHandler.ProcessExecutionAnalysisContext

Overrides:

nextExecutionInputBatches in class SimpleAbstractTurnContext

createInputBatch

protected DistributedProcessHandler.ModelWithDependencies<BatchModel> createInputBatch(SimpleBatchModel _inputBatch)