Class DefaultRuleEngineJobService
java.lang.Object
de.hybris.platform.ruleengineservices.jobs.impl.DefaultRuleEngineJobService
- All Implemented Interfaces:
RuleEngineJobService
Default implementation of the
RuleEngineJobService-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionintcountRunningJobs(String ruleEngineJobCode) Checks how many currently active cron jobs a RuleEngineJob hasprotected RuleEngineJobModelcreateNewRuleEngineJob(String jobCode, String springBeanName) protected voidcreateTriggerForCronJob(CronJobModel cronJob) protected ClusterServiceprotected CronJobServiceprotected ModelServiceprotected RuleEngineCronJobDAOprotected Optional<RuleEngineJobModel>getRuleEngineJob(String jobCode) getRuleEngineJob(String jobCode, String springBeanName) Retrieves (or creates one if absent) the RuleEngineJob, identified by given spring Bean nameprotected StringbooleanChecks whether the RuleEngineJob has any active cron jobsprotected voidlinkCronJobToJob(RuleEngineJobModel ruleEngineJob, RuleEngineCronJobModel ruleEngineCronJob) voidsetClusterService(ClusterService clusterService) voidsetCronJobService(CronJobService cronJobService) voidsetModelService(ModelService modelService) voidsetRuleEngineCronJobDAO(RuleEngineCronJobDAO ruleEngineCronJobDAO) voidsetTriggerCronExpression(String triggerCronExpression) triggerCronJob(String ruleEngineJobCode, String jobPerformableBeanName, Supplier<RuleEngineCronJobModel> cronJobSupplier) Given the rule engine Job, create a new instance ofRuleEngineCronJobModeland run it if no other associated cron job is currently in execution
-
Constructor Details
-
DefaultRuleEngineJobService
public DefaultRuleEngineJobService()
-
-
Method Details
-
getRuleEngineJob
Description copied from interface:RuleEngineJobServiceRetrieves (or creates one if absent) the RuleEngineJob, identified by given spring Bean name- Specified by:
getRuleEngineJobin interfaceRuleEngineJobService- Parameters:
jobCode- job codespringBeanName- spring bean name- Returns:
- an instance of
RuleEngineJobModel
-
isRunning
Description copied from interface:RuleEngineJobServiceChecks whether the RuleEngineJob has any active cron jobs- Specified by:
isRunningin interfaceRuleEngineJobService- Parameters:
ruleEngineJobCode- code of the Job to check against- Returns:
- boolean indicating whether this job has any active cron jobs
-
countRunningJobs
Description copied from interface:RuleEngineJobServiceChecks how many currently active cron jobs a RuleEngineJob has- Specified by:
countRunningJobsin interfaceRuleEngineJobService- Parameters:
ruleEngineJobCode- code of the Job to check against- Returns:
- number of active cron jobs currently running
-
triggerCronJob
public RuleEngineCronJobModel triggerCronJob(String ruleEngineJobCode, String jobPerformableBeanName, Supplier<RuleEngineCronJobModel> cronJobSupplier) Description copied from interface:RuleEngineJobServiceGiven the rule engine Job, create a new instance ofRuleEngineCronJobModeland run it if no other associated cron job is currently in execution- Specified by:
triggerCronJobin interfaceRuleEngineJobService- Parameters:
ruleEngineJobCode- the code of the Job to create the cron job withjobPerformableBeanName- name of a bean ofJobPerformableto runcronJobSupplier- a supplier for the instance ofRuleEngineCronJobModel- Returns:
- instance of
RuleEngineCronJobModel
-
linkCronJobToJob
protected void linkCronJobToJob(RuleEngineJobModel ruleEngineJob, RuleEngineCronJobModel ruleEngineCronJob) -
getRuleEngineJob
-
createNewRuleEngineJob
-
createTriggerForCronJob
-
getModelService
-
setModelService
-
getRuleEngineCronJobDAO
-
setRuleEngineCronJobDAO
-
setTriggerCronExpression
-
getTriggerCronExpression
-
getCronJobService
-
setCronJobService
-
getClusterService
-
setClusterService
-