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

Class DefaultRuleEngineCronJobSupplierFactory

java.lang.Object

de.hybris.platform.ruleengineservices.jobs.impl.DefaultRuleEngineCronJobSupplierFactory

All Implemented Interfaces:

RuleEngineCronJobSupplierFactory

public class DefaultRuleEngineCronJobSupplierFactory
extends java.lang.Object
implements RuleEngineCronJobSupplierFactory

Default implementation of the rule engine cron job supplier factory

Constructor Summary

Constructors

Constructor	Description
DefaultRuleEngineCronJobSupplierFactory()

Method Summary

Modifier and Type	Method	Description
java.util.function.Supplier<RuleEngineCronJobModel>	createAllModulesInitializationSupplier()	Create supplier of RuleEngineCronJobModel for all modules initialization process
java.util.function.Supplier<RuleEngineCronJobModel>	createCompileAndPublishSupplier(java.util.List<SourceRuleModel> rules, java.lang.String moduleName, boolean enableIncrementalUpdate)	Create supplier of RuleEngineCronJobModel for compilation and publishing of specified rules for a module
java.util.function.Supplier<RuleEngineCronJobModel>	createModuleInitializationSupplier(java.lang.String moduleName)	Create supplier of RuleEngineCronJobModel for module initialization process
java.util.function.Supplier<RuleEngineCronJobModel>	createSynchronizeSupplier(java.lang.String srcModuleName, java.lang.String targetModuleName)	Create supplier of RuleEngineCronJobModel for modules synchronization process
java.util.function.Supplier<RuleEngineCronJobModel>	createUndeploySupplier(java.util.List<SourceRuleModel> rules, java.lang.String moduleName)	Create supplier of RuleEngineCronJobModel for undeployment of specified rules for a module
protected ClusterService	getClusterService()
protected java.lang.String	getNodeGroup()
protected java.lang.Integer	getNodeId()
protected RuleEngineCronJobModel	newCronJob()
void	setClusterService(ClusterService clusterService)
void	setNodeGroup(java.lang.String nodeGroup)
void	setNodeId(java.lang.Integer nodeId)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRuleEngineCronJobSupplierFactory

public DefaultRuleEngineCronJobSupplierFactory()

Method Detail

createCompileAndPublishSupplier

public java.util.function.Supplier<RuleEngineCronJobModel> createCompileAndPublishSupplier(java.util.List<SourceRuleModel> rules,
                                                                                           java.lang.String moduleName,
                                                                                           boolean enableIncrementalUpdate)

Description copied from interface: RuleEngineCronJobSupplierFactory

Create supplier of RuleEngineCronJobModel for compilation and publishing of specified rules for a module

Specified by:

createCompileAndPublishSupplier in interface RuleEngineCronJobSupplierFactory

Parameters:

rules - list of SourceRuleModel entities

moduleName - kie module name

enableIncrementalUpdate - boolean flag that identifies whether to follow incremental update process

Returns:

supplier of RuleEngineCronJobModel instance

createUndeploySupplier

public java.util.function.Supplier<RuleEngineCronJobModel> createUndeploySupplier(java.util.List<SourceRuleModel> rules,
                                                                                  java.lang.String moduleName)

Description copied from interface: RuleEngineCronJobSupplierFactory

Create supplier of RuleEngineCronJobModel for undeployment of specified rules for a module

Specified by:

createUndeploySupplier in interface RuleEngineCronJobSupplierFactory

Parameters:

rules - list of SourceRuleModel entities

moduleName - kie module name

Returns:

supplier of RuleEngineCronJobModel instance

createSynchronizeSupplier

public java.util.function.Supplier<RuleEngineCronJobModel> createSynchronizeSupplier(java.lang.String srcModuleName,
                                                                                     java.lang.String targetModuleName)

Description copied from interface: RuleEngineCronJobSupplierFactory

Create supplier of RuleEngineCronJobModel for modules synchronization process

Specified by:

createSynchronizeSupplier in interface RuleEngineCronJobSupplierFactory

Parameters:

srcModuleName - source kie module name

targetModuleName - name of the target kie module

Returns:

supplier of RuleEngineCronJobModel instance

createModuleInitializationSupplier

public java.util.function.Supplier<RuleEngineCronJobModel> createModuleInitializationSupplier(java.lang.String moduleName)

Description copied from interface: RuleEngineCronJobSupplierFactory

Create supplier of RuleEngineCronJobModel for module initialization process

Specified by:

createModuleInitializationSupplier in interface RuleEngineCronJobSupplierFactory

Parameters:

moduleName - kie module name

Returns:

supplier of RuleEngineCronJobModel instance

createAllModulesInitializationSupplier

public java.util.function.Supplier<RuleEngineCronJobModel> createAllModulesInitializationSupplier()

Description copied from interface: RuleEngineCronJobSupplierFactory

Create supplier of RuleEngineCronJobModel for all modules initialization process

Specified by:

createAllModulesInitializationSupplier in interface RuleEngineCronJobSupplierFactory

Returns:

supplier of RuleEngineCronJobModel instance

newCronJob

protected RuleEngineCronJobModel newCronJob()

getNodeId

protected java.lang.Integer getNodeId()

setNodeId

public void setNodeId(java.lang.Integer nodeId)

getNodeGroup

protected java.lang.String getNodeGroup()

setNodeGroup

public void setNodeGroup(java.lang.String nodeGroup)

getClusterService

protected ClusterService getClusterService()

setClusterService

public void setClusterService(ClusterService clusterService)