Package de.hybris.platform.processing.distributed.defaultimpl

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 java.lang.Object
implements org.springframework.context.ApplicationContextAware

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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(org.springframework.context.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(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.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 java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getProcessStatus

public ProcessStatus getProcessStatus(DistributedProcessModel process)