Class DefaultRuleEngineCronJobLauncher
java.lang.Object
de.hybris.platform.ruleengineservices.jobs.impl.DefaultRuleEngineCronJobLauncher
- All Implemented Interfaces:
RuleEngineCronJobLauncher
Default implementation of the rule engine cron job launcher
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected static final Stringprotected static final Stringprotected static final Stringprotected static final Stringprotected static final Stringprotected static final Stringprotected static final Stringprotected static final Stringprotected static final Stringprotected static final String -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected L10NServiceprotected intgetPossibleJobCodes(String template) getPossibleModuleSyncJobCodes(String moduleName) protected RuleEngineCronJobSupplierFactoryprotected RuleEngineJobServiceprotected RulesModuleDaovoidsetL10nService(L10NService l10nService) voidsetMaximumNumberOfParallelCronJobs(int maximumNumberOfParallelCronJobs) voidsetRuleEngineCronJobSupplierFactory(RuleEngineCronJobSupplierFactory ruleEngineCronJobSupplierFactory) voidsetRuleEngineJobService(RuleEngineJobService ruleEngineJobService) voidsetRulesModuleDao(RulesModuleDao rulesModuleDao) Trigger the whole rule engine (for all modules) initializationtriggerCompileAndPublish(List<SourceRuleModel> rules, String moduleName, boolean enableIncrementalUpdate) Trigger the compilation and publishing of specified rules for a moduletriggerModuleInitialization(String moduleName) Trigger the specified module initialization tasktriggerSynchronizeModules(String srcModuleName, String targetModuleName) Trigger the modules synchronization tasktriggerUndeployRules(List<SourceRuleModel> rules, String moduleName) Trigger the specified rules undeployment processprotected voidverifyIfJobsAreNotRunning(String... jobCodes)
-
Field Details
-
COMPILE_PUBLISH_PERFORMABLE_BEAN_NAME
- See Also:
-
COMPILE_PUBLISH_JOB_CODE_TEMPLATE
- See Also:
-
UNDEPLOY_PERFORMABLE_BEAN_NAME
- See Also:
-
UNDEPLOY_JOB_CODE_TEMPLATE
- See Also:
-
MODULES_SYNCH_PERFORMABLE_BEAN_NAME
- See Also:
-
MODULES_SYNCH_JOB_CODE_TEMPLATE
- See Also:
-
MODULE_INIT_PERFORMABLE_BEAN_NAME
- See Also:
-
MODULE_INIT_JOB_CODE_TEMPLATE
- See Also:
-
ALL_MODULES_INIT_PERFORMABLE_BEAN_NAME
- See Also:
-
ALL_MODULES_INIT_JOB_CODE
- See Also:
-
-
Constructor Details
-
DefaultRuleEngineCronJobLauncher
public DefaultRuleEngineCronJobLauncher()
-
-
Method Details
-
triggerCompileAndPublish
public RuleEngineCronJobModel triggerCompileAndPublish(List<SourceRuleModel> rules, String moduleName, boolean enableIncrementalUpdate) Description copied from interface:RuleEngineCronJobLauncherTrigger the compilation and publishing of specified rules for a module- Specified by:
triggerCompileAndPublishin interfaceRuleEngineCronJobLauncher- Parameters:
rules- a list ofSourceRuleModelto compile and publishmoduleName- a kie module nameenableIncrementalUpdate- boolean indicating whether the incremental update of rule engine must be employed- Returns:
- the instance of triggered
RuleEngineCronJobModel
-
triggerUndeployRules
Description copied from interface:RuleEngineCronJobLauncherTrigger the specified rules undeployment process- Specified by:
triggerUndeployRulesin interfaceRuleEngineCronJobLauncher- Parameters:
rules- a list ofSourceRuleModelto undeploymoduleName- a kie module name to undeploy the rules for- Returns:
- the instance of triggered
RuleEngineCronJobModel
-
triggerSynchronizeModules
public RuleEngineCronJobModel triggerSynchronizeModules(String srcModuleName, String targetModuleName) Description copied from interface:RuleEngineCronJobLauncherTrigger the modules synchronization task- Specified by:
triggerSynchronizeModulesin interfaceRuleEngineCronJobLauncher- Parameters:
srcModuleName- a name of the kie module to synchronise the rules fromtargetModuleName- a name of the kie module to synchronise the rules to- Returns:
- the instance of triggered
RuleEngineCronJobModel
-
triggerModuleInitialization
Description copied from interface:RuleEngineCronJobLauncherTrigger the specified module initialization task- Specified by:
triggerModuleInitializationin interfaceRuleEngineCronJobLauncher- Parameters:
moduleName- a name of the kie module to initialize- Returns:
- the instance of triggered
RuleEngineCronJobModel
-
triggerAllModulesInitialization
Description copied from interface:RuleEngineCronJobLauncherTrigger the whole rule engine (for all modules) initialization- Specified by:
triggerAllModulesInitializationin interfaceRuleEngineCronJobLauncher- Returns:
- the instance of triggered
RuleEngineCronJobModel
-
getPossibleModuleSyncJobCodes
-
getPossibleModuleSyncJobCodes
-
getPossibleJobCodes
-
getAllRuleModuleNames
-
verifyIfJobsAreNotRunning
-
getRuleEngineJobService
-
setRuleEngineJobService
-
getRulesModuleDao
-
setRulesModuleDao
-
getRuleEngineCronJobSupplierFactory
-
setRuleEngineCronJobSupplierFactory
public void setRuleEngineCronJobSupplierFactory(RuleEngineCronJobSupplierFactory ruleEngineCronJobSupplierFactory) -
getMaximumNumberOfParallelCronJobs
protected int getMaximumNumberOfParallelCronJobs() -
setMaximumNumberOfParallelCronJobs
public void setMaximumNumberOfParallelCronJobs(int maximumNumberOfParallelCronJobs) -
getL10nService
-
setL10nService
-