Class SimpleAbstractDistributedProcessHandler
java.lang.Object
de.hybris.platform.processing.distributed.simple.SimpleAbstractDistributedProcessHandler
- All Implemented Interfaces:
DistributedProcessHandler
- Direct Known Subclasses:
SimpleDistributedProcessHandler,SimpleScriptingDistributedProcessHandler
public abstract class SimpleAbstractDistributedProcessHandler
extends Object
implements DistributedProcessHandler
-
Nested Class Summary
Nested classes/interfaces inherited from interface de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHandler
DistributedProcessHandler.ModelWithDependencies<T extends ItemModel>, DistributedProcessHandler.ProcessCreationContext, DistributedProcessHandler.ProcessExecutionAnalysisContext, DistributedProcessHandler.ProcessInitializationContext -
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final DistributedProcessServiceprotected final FlexibleSearchServiceprotected static final org.slf4j.Loggerprotected final ModelServicestatic final longstatic final long -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedSimpleAbstractDistributedProcessHandler(ModelService modelService, FlexibleSearchService flexibleSearchService, DistributedProcessService distributedProcessService) -
Method Summary
Modifier and TypeMethodDescriptioncalculateProgress(DistributedProcessModel process) createProcessCreationContext(ProcessCreationData processData) createResultBatch(BatchModel inputBatch) voidonFinished(DistributedProcessModel process) protected SimpleProcessCreationContextprotected BatchModelabstract voidprocessBatch(SimpleBatchModel inputBatch) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHandler
getTypesWithDisabledUniquenessCheck, updateStatusInformation
-
Field Details
-
LOG
protected static final org.slf4j.Logger LOG -
REMAINING_WORKLOAD
public static final long REMAINING_WORKLOAD- See Also:
-
WORK_DONE
public static final long WORK_DONE- See Also:
-
modelService
-
flexibleSearchService
-
distributedProcessService
-
-
Constructor Details
-
SimpleAbstractDistributedProcessHandler
protected SimpleAbstractDistributedProcessHandler(ModelService modelService, FlexibleSearchService flexibleSearchService, DistributedProcessService distributedProcessService)
-
-
Method Details
-
createProcessCreationContext
- Specified by:
createProcessCreationContextin interfaceDistributedProcessHandler
-
prepareProcessCreationContext
protected SimpleProcessCreationContext prepareProcessCreationContext(SimpleAbstractDistributedProcessCreationData processData) -
createProcessInitializationContext
public DistributedProcessHandler.ProcessInitializationContext createProcessInitializationContext(DistributedProcessModel process) - Specified by:
createProcessInitializationContextin interfaceDistributedProcessHandler
-
createResultBatch
public DistributedProcessHandler.ModelWithDependencies<BatchModel> createResultBatch(BatchModel inputBatch) - Specified by:
createResultBatchin interfaceDistributedProcessHandler
-
processBatch
-
prepareResultBatch
-
createProcessExecutionAnalysisContext
public DistributedProcessHandler.ProcessExecutionAnalysisContext createProcessExecutionAnalysisContext(DistributedProcessModel process) - Specified by:
createProcessExecutionAnalysisContextin interfaceDistributedProcessHandler
-
onFinished
- Specified by:
onFinishedin interfaceDistributedProcessHandler
-
calculateProgress
- Specified by:
calculateProgressin interfaceDistributedProcessHandler
-