Class DefaultRuleEngineCronJobSupplierFactory
java.lang.Object
de.hybris.platform.ruleengineservices.jobs.impl.DefaultRuleEngineCronJobSupplierFactory
- All Implemented Interfaces:
RuleEngineCronJobSupplierFactory
public class DefaultRuleEngineCronJobSupplierFactory
extends Object
implements RuleEngineCronJobSupplierFactory
Default implementation of the rule engine cron job supplier factory
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionCreate supplier ofRuleEngineCronJobModelfor all modules initialization processcreateCompileAndPublishSupplier(List<SourceRuleModel> rules, String moduleName, boolean enableIncrementalUpdate) Create supplier ofRuleEngineCronJobModelfor compilation and publishing of specified rules for a modulecreateModuleInitializationSupplier(String moduleName) Create supplier ofRuleEngineCronJobModelfor module initialization processcreateSynchronizeSupplier(String srcModuleName, String targetModuleName) Create supplier ofRuleEngineCronJobModelfor modules synchronization processcreateUndeploySupplier(List<SourceRuleModel> rules, String moduleName) Create supplier ofRuleEngineCronJobModelfor undeployment of specified rules for a moduleprotected ClusterServiceprotected Stringprotected Integerprotected RuleEngineCronJobModelvoidsetClusterService(ClusterService clusterService) voidsetNodeGroup(String nodeGroup) void
-
Constructor Details
-
DefaultRuleEngineCronJobSupplierFactory
public DefaultRuleEngineCronJobSupplierFactory()
-
-
Method Details
-
createCompileAndPublishSupplier
public Supplier<RuleEngineCronJobModel> createCompileAndPublishSupplier(List<SourceRuleModel> rules, String moduleName, boolean enableIncrementalUpdate) Description copied from interface:RuleEngineCronJobSupplierFactoryCreate supplier ofRuleEngineCronJobModelfor compilation and publishing of specified rules for a module- Specified by:
createCompileAndPublishSupplierin interfaceRuleEngineCronJobSupplierFactory- Parameters:
rules- list ofSourceRuleModelentitiesmoduleName- kie module nameenableIncrementalUpdate- boolean flag that identifies whether to follow incremental update process- Returns:
- supplier of
RuleEngineCronJobModelinstance
-
createUndeploySupplier
public Supplier<RuleEngineCronJobModel> createUndeploySupplier(List<SourceRuleModel> rules, String moduleName) Description copied from interface:RuleEngineCronJobSupplierFactoryCreate supplier ofRuleEngineCronJobModelfor undeployment of specified rules for a module- Specified by:
createUndeploySupplierin interfaceRuleEngineCronJobSupplierFactory- Parameters:
rules- list ofSourceRuleModelentitiesmoduleName- kie module name- Returns:
- supplier of
RuleEngineCronJobModelinstance
-
createSynchronizeSupplier
public Supplier<RuleEngineCronJobModel> createSynchronizeSupplier(String srcModuleName, String targetModuleName) Description copied from interface:RuleEngineCronJobSupplierFactoryCreate supplier ofRuleEngineCronJobModelfor modules synchronization process- Specified by:
createSynchronizeSupplierin interfaceRuleEngineCronJobSupplierFactory- Parameters:
srcModuleName- source kie module nametargetModuleName- name of the target kie module- Returns:
- supplier of
RuleEngineCronJobModelinstance
-
createModuleInitializationSupplier
Description copied from interface:RuleEngineCronJobSupplierFactoryCreate supplier ofRuleEngineCronJobModelfor module initialization process- Specified by:
createModuleInitializationSupplierin interfaceRuleEngineCronJobSupplierFactory- Parameters:
moduleName- kie module name- Returns:
- supplier of
RuleEngineCronJobModelinstance
-
createAllModulesInitializationSupplier
Description copied from interface:RuleEngineCronJobSupplierFactoryCreate supplier ofRuleEngineCronJobModelfor all modules initialization process- Specified by:
createAllModulesInitializationSupplierin interfaceRuleEngineCronJobSupplierFactory- Returns:
- supplier of
RuleEngineCronJobModelinstance
-
newCronJob
-
getNodeId
-
setNodeId
-
getNodeGroup
-
setNodeGroup
-
getClusterService
-
setClusterService
-