Class DefaultRuleEngineJobExecutionSynchronizer
- java.lang.Object
-
- de.hybris.platform.ruleengineservices.jobs.impl.DefaultRuleEngineJobExecutionSynchronizer
-
- All Implemented Interfaces:
RuleEngineJobExecutionSynchronizer
public class DefaultRuleEngineJobExecutionSynchronizer extends java.lang.Object implements RuleEngineJobExecutionSynchronizer
Default implementation ofRuleEngineJobExecutionSynchronizercontract
-
-
Constructor Summary
Constructors Constructor Description DefaultRuleEngineJobExecutionSynchronizer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanacquireLock(RuleEngineCronJobModel cronJob)Performs lock acquisition of all the required resources for the given jobprotected ModelServicegetModelService()protected RulesModuleDaogetRulesModuleDao()protected java.util.List<AbstractRulesModuleModel>getRulesModules(RuleEngineCronJobModel cronJob)protected java.util.List<AbstractRulesModuleModel>getRulesModules(java.lang.String moduleName)voidreleaseLock(RuleEngineCronJobModel cronJob)Releases locks of all of the previously acquired resources for the given jobprotected java.lang.StringruleModulesAsString(java.util.List<AbstractRulesModuleModel> modules)protected voidsetLockAcquired(RuleEngineCronJobModel cronJob, java.util.List<AbstractRulesModuleModel> modules, boolean value)voidsetModelService(ModelService modelService)voidsetRulesModuleDao(RulesModuleDao rulesModuleDao)
-
-
-
Method Detail
-
acquireLock
public boolean acquireLock(RuleEngineCronJobModel cronJob)
Description copied from interface:RuleEngineJobExecutionSynchronizerPerforms lock acquisition of all the required resources for the given job- Specified by:
acquireLockin interfaceRuleEngineJobExecutionSynchronizer- Parameters:
cronJob- - cron job instance- Returns:
truein case locks have been successfully acquired,false- otherwise
-
releaseLock
public void releaseLock(RuleEngineCronJobModel cronJob)
Description copied from interface:RuleEngineJobExecutionSynchronizerReleases locks of all of the previously acquired resources for the given job- Specified by:
releaseLockin interfaceRuleEngineJobExecutionSynchronizer- Parameters:
cronJob- - cron job instance
-
setLockAcquired
protected void setLockAcquired(RuleEngineCronJobModel cronJob, java.util.List<AbstractRulesModuleModel> modules, boolean value)
-
getRulesModules
protected java.util.List<AbstractRulesModuleModel> getRulesModules(RuleEngineCronJobModel cronJob)
-
getRulesModules
protected java.util.List<AbstractRulesModuleModel> getRulesModules(java.lang.String moduleName)
-
ruleModulesAsString
protected java.lang.String ruleModulesAsString(java.util.List<AbstractRulesModuleModel> modules)
-
getRulesModuleDao
protected RulesModuleDao getRulesModuleDao()
-
setRulesModuleDao
public void setRulesModuleDao(RulesModuleDao rulesModuleDao)
-
getModelService
protected ModelService getModelService()
-
setModelService
public void setModelService(ModelService modelService)
-
-