Package de.hybris.platform.catalog.job

Class CompositeJobPerformable

java.lang.Object

de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable<CompositeCronJobModel>

de.hybris.platform.catalog.job.CompositeJobPerformable

All Implemented Interfaces:

JobPerformable<CompositeCronJobModel>

public class CompositeJobPerformable
extends AbstractJobPerformable<CompositeCronJobModel>

Executes synchronously in order of CompositeCronJobModel.getCompositeEntries() underlying CronJobModel or TriggerModel created upon CompositeEntryModel.getTriggerableJob().

CronJobModel instances are fired by CronJobService.performCronJob(CronJobModel, boolean)

TriggerModel instance are fired by TriggerService.activate(TriggerModel).

Field Summary

Fields inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable

flexibleSearchService, modelService, sessionService

Constructor Summary

Constructors

Constructor	Description
CompositeJobPerformable()

Method Summary

Modifier and Type	Method	Description
protected CronJobModel	executeCompositeEntry(CompositeEntryModel compositeEntryModel)	Executes a CompositeEntryModel.getTriggerableJob() or CompositeEntryModel.getExecutableCronJob() respectively for a given compositeEntryModel.
protected CronJobModel	getRefreshedCronJobModel(CronJobModel cronJobModel)	Performs ModelService.refresh(Object model) on given cronJobModel and returns it.
PerformResult	perform(CompositeCronJobModel cronJob)	The execution body for a ServicelayerJob.
void	setCronJobService(CronJobService cronJobService)
void	setWait(int wait)	Sets the wait time in poll loop checking the CompositeEntryModel.getExecutableCronJob() or CompositeEntryModel.getTriggerableJob() has ended.

Methods inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable

clearAbortRequestedIfNeeded, isAbortable, isPerformable, setFlexibleSearchService, setModelService, setSessionService

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeJobPerformable

public CompositeJobPerformable()

Method Detail

setWait

public void setWait(int wait)

Sets the wait time in poll loop checking the CompositeEntryModel.getExecutableCronJob() or CompositeEntryModel.getTriggerableJob() has ended.

setCronJobService

public void setCronJobService(CronJobService cronJobService)

perform

public PerformResult perform(CompositeCronJobModel cronJob)

Description copied from interface: JobPerformable

The execution body for a ServicelayerJob. Implement here your execution logic. It can be called synchronous or asynchronous. So be aware of thread-safety. Method will return a result object saying if the execution has reached end and if it was successful.

Specified by:

perform in interface JobPerformable<CompositeCronJobModel>

Specified by:

perform in class AbstractJobPerformable<CompositeCronJobModel>

Parameters:

cronJob - the related CronJob in whose context the execution will be performed.

Returns:

a PerformResult that indicates whether the execution was successfully executed or not and has finished or not.

getRefreshedCronJobModel

protected CronJobModel getRefreshedCronJobModel(CronJobModel cronJobModel)

Performs ModelService.refresh(Object model) on given cronJobModel and returns it.

executeCompositeEntry

protected CronJobModel executeCompositeEntry(CompositeEntryModel compositeEntryModel)

Executes a CompositeEntryModel.getTriggerableJob() or CompositeEntryModel.getExecutableCronJob() respectively for a given compositeEntryModel.