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

Class DefaultRuleEngineJobExecutionSynchronizer

java.lang.Object

de.hybris.platform.ruleengineservices.jobs.impl.DefaultRuleEngineJobExecutionSynchronizer

All Implemented Interfaces:

RuleEngineJobExecutionSynchronizer

public class DefaultRuleEngineJobExecutionSynchronizer
extends Object
implements RuleEngineJobExecutionSynchronizer

Default implementation of RuleEngineJobExecutionSynchronizer contract

Constructor Summary

Constructors

Constructor	Description
DefaultRuleEngineJobExecutionSynchronizer()

Method Summary

Modifier and Type	Method	Description
boolean	acquireLock(RuleEngineCronJobModel cronJob)	Performs lock acquisition of all the required resources for the given job
protected ModelService	getModelService()
protected RulesModuleDao	getRulesModuleDao()
protected List<AbstractRulesModuleModel>	getRulesModules(RuleEngineCronJobModel cronJob)
protected List<AbstractRulesModuleModel>	getRulesModules(String moduleName)
void	releaseLock(RuleEngineCronJobModel cronJob)	Releases locks of all of the previously acquired resources for the given job
protected String	ruleModulesAsString(List<AbstractRulesModuleModel> modules)
protected void	setLockAcquired(RuleEngineCronJobModel cronJob, List<AbstractRulesModuleModel> modules, boolean value)
void	setModelService(ModelService modelService)
void	setRulesModuleDao(RulesModuleDao rulesModuleDao)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultRuleEngineJobExecutionSynchronizer

public DefaultRuleEngineJobExecutionSynchronizer()

Method Details

acquireLock

public boolean acquireLock(RuleEngineCronJobModel cronJob)

Description copied from interface: RuleEngineJobExecutionSynchronizer

Performs lock acquisition of all the required resources for the given job

Specified by:

acquireLock in interface RuleEngineJobExecutionSynchronizer

Parameters:

cronJob - - cron job instance

Returns:

true in case locks have been successfully acquired, false - otherwise

releaseLock

public void releaseLock(RuleEngineCronJobModel cronJob)

Description copied from interface: RuleEngineJobExecutionSynchronizer

Releases locks of all of the previously acquired resources for the given job

Specified by:

releaseLock in interface RuleEngineJobExecutionSynchronizer

Parameters:

cronJob - - cron job instance

setLockAcquired

protected void setLockAcquired(RuleEngineCronJobModel cronJob,
 List<AbstractRulesModuleModel> modules,
 boolean value)

getRulesModules

protected List<AbstractRulesModuleModel> getRulesModules(RuleEngineCronJobModel cronJob)

getRulesModules

protected List<AbstractRulesModuleModel> getRulesModules(String moduleName)

ruleModulesAsString

protected String ruleModulesAsString(List<AbstractRulesModuleModel> modules)

getRulesModuleDao

protected RulesModuleDao getRulesModuleDao()

setRulesModuleDao

public void setRulesModuleDao(RulesModuleDao rulesModuleDao)

getModelService

protected ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)