de.hybris.platform.processing.distributed.defaultimpl

Class Controller

java.lang.Object

de.hybris.platform.processing.distributed.defaultimpl.Controller

public class Controller
extends Object

Constructor Summary

Constructors

Constructor and Description
Controller(ModelService modelService, FlexibleSearchService flexibleSearchService, Scheduler scheduler)

Method Summary

Modifier and Type	Method and Description
DistributedProcessModel	analyseExecutionResults(DistributedProcessModel process)
DistributedProcessModel	createProcess(ProcessCreationData processData)
ProcessStatus	getProcessStatus(DistributedProcessModel process)
DistributedProcessModel	initializeProcess(DistributedProcessModel process)
DistributedProcessModel	requestToStopProcess(DistributedProcessModel process)
DistributedProcessModel	scheduleExecution(DistributedProcessModel process)
void	setApplicationContext(ApplicationContext applicationContext)
DistributedProcessModel	startProcess(DistributedProcessModel process)
DistributedProcessModel	stopProcess(DistributedProcessModel process)
DistributedProcessModel	waitForProcess(DistributedProcessModel process, long maxWaitTimeInSeconds)

Methods inherited from class java.lang.Object

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

Constructor Detail

Controller

public Controller(ModelService modelService,
                  FlexibleSearchService flexibleSearchService,
                  Scheduler scheduler)

Method Detail

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Throws:

BeansException

createProcess

public DistributedProcessModel createProcess(ProcessCreationData processData)

startProcess

public DistributedProcessModel startProcess(DistributedProcessModel process)

initializeProcess

public DistributedProcessModel initializeProcess(DistributedProcessModel process)

scheduleExecution

public DistributedProcessModel scheduleExecution(DistributedProcessModel process)

analyseExecutionResults

public DistributedProcessModel analyseExecutionResults(DistributedProcessModel process)

requestToStopProcess

public DistributedProcessModel requestToStopProcess(DistributedProcessModel process)

stopProcess

public DistributedProcessModel stopProcess(DistributedProcessModel process)

waitForProcess

public DistributedProcessModel waitForProcess(DistributedProcessModel process,
                                              long maxWaitTimeInSeconds)
                                       throws InterruptedException

Throws:

InterruptedException

getProcessStatus

public ProcessStatus getProcessStatus(DistributedProcessModel process)