Package de.hybris.platform.ruleengineservices.jobs.impl

Class DefaultRuleEngineJobService

java.lang.Object

de.hybris.platform.ruleengineservices.jobs.impl.DefaultRuleEngineJobService

All Implemented Interfaces:

RuleEngineJobService

public class DefaultRuleEngineJobService
extends java.lang.Object
implements RuleEngineJobService

Default implementation of the RuleEngineJobService

Constructor Summary

Constructors

Constructor	Description
DefaultRuleEngineJobService()

Method Summary

Modifier and Type	Method	Description
int	countRunningJobs(java.lang.String ruleEngineJobCode)	Checks how many currently active cron jobs a RuleEngineJob has
protected RuleEngineJobModel	createNewRuleEngineJob(java.lang.String jobCode, java.lang.String springBeanName)
protected void	createTriggerForCronJob(CronJobModel cronJob)
protected ClusterService	getClusterService()
protected CronJobService	getCronJobService()
protected ModelService	getModelService()
protected RuleEngineCronJobDAO	getRuleEngineCronJobDAO()
protected java.util.Optional<RuleEngineJobModel>	getRuleEngineJob(java.lang.String jobCode)
RuleEngineJobModel	getRuleEngineJob(java.lang.String jobCode, java.lang.String springBeanName)	Retrieves (or creates one if absent) the RuleEngineJob, identified by given spring Bean name
protected java.lang.String	getTriggerCronExpression()
boolean	isRunning(java.lang.String ruleEngineJobCode)	Checks whether the RuleEngineJob has any active cron jobs
protected void	linkCronJobToJob(RuleEngineJobModel ruleEngineJob, RuleEngineCronJobModel ruleEngineCronJob)
void	setClusterService(ClusterService clusterService)
void	setCronJobService(CronJobService cronJobService)
void	setModelService(ModelService modelService)
void	setRuleEngineCronJobDAO(RuleEngineCronJobDAO ruleEngineCronJobDAO)
void	setTriggerCronExpression(java.lang.String triggerCronExpression)
RuleEngineCronJobModel	triggerCronJob(java.lang.String ruleEngineJobCode, java.lang.String jobPerformableBeanName, java.util.function.Supplier<RuleEngineCronJobModel> cronJobSupplier)	Given the rule engine Job, create a new instance of RuleEngineCronJobModel and run it if no other associated cron job is currently in execution

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRuleEngineJobService

public DefaultRuleEngineJobService()

Method Detail

getRuleEngineJob

public RuleEngineJobModel getRuleEngineJob(java.lang.String jobCode,
                                           java.lang.String springBeanName)

Description copied from interface: RuleEngineJobService

Retrieves (or creates one if absent) the RuleEngineJob, identified by given spring Bean name

Specified by:

getRuleEngineJob in interface RuleEngineJobService

Parameters:

jobCode - job code

springBeanName - spring bean name

Returns:

an instance of RuleEngineJobModel

isRunning

public boolean isRunning(java.lang.String ruleEngineJobCode)

Description copied from interface: RuleEngineJobService

Checks whether the RuleEngineJob has any active cron jobs

Specified by:

isRunning in interface RuleEngineJobService

Parameters:

ruleEngineJobCode - code of the Job to check against

Returns:

boolean indicating whether this job has any active cron jobs

countRunningJobs

public int countRunningJobs(java.lang.String ruleEngineJobCode)

Description copied from interface: RuleEngineJobService

Checks how many currently active cron jobs a RuleEngineJob has

Specified by:

countRunningJobs in interface RuleEngineJobService

Parameters:

ruleEngineJobCode - code of the Job to check against

Returns:

number of active cron jobs currently running

triggerCronJob

public RuleEngineCronJobModel triggerCronJob(java.lang.String ruleEngineJobCode,
                                             java.lang.String jobPerformableBeanName,
                                             java.util.function.Supplier<RuleEngineCronJobModel> cronJobSupplier)

Description copied from interface: RuleEngineJobService

Given the rule engine Job, create a new instance of RuleEngineCronJobModel and run it if no other associated cron job is currently in execution

Specified by:

triggerCronJob in interface RuleEngineJobService

Parameters:

ruleEngineJobCode - the code of the Job to create the cron job with

jobPerformableBeanName - name of a bean of JobPerformable to run

cronJobSupplier - a supplier for the instance of RuleEngineCronJobModel

Returns:

instance of RuleEngineCronJobModel

linkCronJobToJob

protected void linkCronJobToJob(RuleEngineJobModel ruleEngineJob,
                                RuleEngineCronJobModel ruleEngineCronJob)

getRuleEngineJob

protected java.util.Optional<RuleEngineJobModel> getRuleEngineJob(java.lang.String jobCode)

createNewRuleEngineJob

protected RuleEngineJobModel createNewRuleEngineJob(java.lang.String jobCode,
                                                    java.lang.String springBeanName)

createTriggerForCronJob

protected void createTriggerForCronJob(CronJobModel cronJob)

getModelService

protected ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)

getRuleEngineCronJobDAO

protected RuleEngineCronJobDAO getRuleEngineCronJobDAO()

setRuleEngineCronJobDAO

public void setRuleEngineCronJobDAO(RuleEngineCronJobDAO ruleEngineCronJobDAO)

setTriggerCronExpression

public void setTriggerCronExpression(java.lang.String triggerCronExpression)

getTriggerCronExpression

protected java.lang.String getTriggerCronExpression()

getCronJobService

protected CronJobService getCronJobService()

setCronJobService

public void setCronJobService(CronJobService cronJobService)

getClusterService

protected ClusterService getClusterService()

setClusterService

public void setClusterService(ClusterService clusterService)