Class Controller
java.lang.Object
de.hybris.platform.processing.distributed.defaultimpl.Controller
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.context.ApplicationContextAware
public class Controller
extends Object
implements org.springframework.context.ApplicationContextAware
-
Constructor Summary
ConstructorsConstructorDescriptionController(ModelService modelService, FlexibleSearchService flexibleSearchService, Scheduler scheduler) -
Method Summary
Modifier and TypeMethodDescriptioncreateProcess(ProcessCreationData processData) getProcessStatus(DistributedProcessModel process) initializeProcess(DistributedProcessModel process) scheduleExecution(DistributedProcessModel process) voidsetApplicationContext(org.springframework.context.ApplicationContext applicationContext) startProcess(DistributedProcessModel process) stopProcess(DistributedProcessModel process) waitForProcess(DistributedProcessModel process, long maxWaitTimeInSeconds)
-
Constructor Details
-
Controller
public Controller(ModelService modelService, FlexibleSearchService flexibleSearchService, Scheduler scheduler)
-
-
Method Details
-
setApplicationContext
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException - Specified by:
setApplicationContextin interfaceorg.springframework.context.ApplicationContextAware- Throws:
org.springframework.beans.BeansException
-
createProcess
-
startProcess
-
initializeProcess
-
scheduleExecution
-
analyseExecutionResults
-
requestToStopProcess
-
stopProcess
-
waitForProcess
public DistributedProcessModel waitForProcess(DistributedProcessModel process, long maxWaitTimeInSeconds) throws InterruptedException - Throws:
InterruptedException
-
getProcessStatus
-