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

Class DefaultDistributedProcessService

java.lang.Object

de.hybris.platform.processing.distributed.defaultimpl.DefaultDistributedProcessService

All Implemented Interfaces:

DistributedProcessService

public class DefaultDistributedProcessService
extends Object
implements DistributedProcessService

Constructor Summary

Constructors

Constructor	Description
DefaultDistributedProcessService(ModelService modelService, FlexibleSearchService flexibleSearchService, Controller controller)

Method Summary

Modifier and Type	Method	Description
<T extends DistributedProcessModel> T	create(ProcessCreationData creationData)	Creates process based on ProcessCreationData
ProcessStatus	getCurrentStatus(String processCode)	Get current status of distributed process
<T extends DistributedProcessModel> T	requestToStop(String processCode)	Mark process with given code as requested to stop.
<T extends DistributedProcessModel> T	start(String processCode)	Starts process with given code
<T extends DistributedProcessModel> T	wait(String processCode, long maxWaitTimeInSeconds)	Wait for process to be finished.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultDistributedProcessService

public DefaultDistributedProcessService(ModelService modelService,
 FlexibleSearchService flexibleSearchService,
 Controller controller)

Method Details

create

public <T extends DistributedProcessModel> T create(ProcessCreationData creationData)

Description copied from interface: DistributedProcessService

Creates process based on ProcessCreationData

Specified by:

create in interface DistributedProcessService

Parameters:

creationData - process creation data

Returns:

created process

start

public <T extends DistributedProcessModel> T start(String processCode)

Description copied from interface: DistributedProcessService

Starts process with given code

Specified by:

start in interface DistributedProcessService

Parameters:

processCode - code of process to be started

Returns:

started process

requestToStop

public <T extends DistributedProcessModel> T requestToStop(String processCode)

Description copied from interface: DistributedProcessService

Mark process with given code as requested to stop. It doesn't stop the process.

Specified by:

requestToStop in interface DistributedProcessService

Parameters:

processCode - code of process to be stopped

Returns:

process

wait

public <T extends DistributedProcessModel> T wait(String processCode,
 long maxWaitTimeInSeconds)
                                           throws InterruptedException

Description copied from interface: DistributedProcessService

Wait for process to be finished. Process is considered as finish if it's in state DistributedProcessState.SUCCEEDED, DistributedProcessState.STOPPED or DistributedProcessState.FAILED. It wait's for a given time and if it returns caller need to check whether the process is really finished.

Specified by:

wait in interface DistributedProcessService

Parameters:

processCode - code of process to be waited for

maxWaitTimeInSeconds - time in seconds

Returns:

process

Throws:

InterruptedException

getCurrentStatus

public ProcessStatus getCurrentStatus(String processCode)

Description copied from interface: DistributedProcessService

Get current status of distributed process

Specified by:

getCurrentStatus in interface DistributedProcessService

Parameters:

processCode - code of process

Returns:

current status