de.hybris.platform.ruleengine.init.impl

Class DefaultRulePublishingSpliterator

java.lang.Object

de.hybris.platform.ruleengine.init.impl.DefaultRulePublishingSpliterator

All Implemented Interfaces:

RulePublishingSpliterator

public class DefaultRulePublishingSpliterator
extends java.lang.Object
implements RulePublishingSpliterator

Default implementation of RulePublishingSpliterator

Constructor Summary

Constructors

Constructor and Description
DefaultRulePublishingSpliterator()

Method Summary

Modifier and Type	Method and Description
protected ResultItem	addNewResultItemOf(RuleEngineActionResult result, MessageLevel messageLevel, java.lang.String message)
protected RuleEngineActionResult	addRulesBuilder(java.util.List<KieBuilder> kieBuilders, KieModuleModel kieModuleModel, ReleaseId releaseId, java.util.List<java.lang.String> ruleUuids, KIEModuleCacheBuilder cache)
protected Results	createKieBuilderErrorResult(DroolsRuleModel rule, java.lang.Exception e)
protected RuleEngineActionResult	createNewResult(Results results)
protected java.lang.Thread	createNewWorker(java.util.List<KieBuilder> kieBuilders, KieModuleModel kieModuleModel, ReleaseId releaseId, java.util.List<java.lang.String> ruleUuids, java.util.List<RuleEngineActionResult> ruleEngineActionResults, KIEModuleCacheBuilder cache)
protected EngineRuleDao	getEngineRuleDao()
protected KieServices	getKieServices()
protected RuleEngineBootstrap<KieServices,KieContainer,DroolsKIEModuleModel>	getRuleEngineBootstrap()
protected SuspendResumeTaskManager	getSuspendResumeTaskManager()
protected TaskContext	getTaskContext()
RulePublishingFuture	publishRulesAsync(KieModuleModel kieModuleModel, ReleaseId containerReleaseId, java.util.List<java.lang.String> ruleUuids, KIEModuleCacheBuilder cache) split and compile multiple rules in parallel
void	setEngineRuleDao(EngineRuleDao engineRuleDao)
void	setRuleEngineBootstrap(RuleEngineBootstrap<KieServices,KieContainer,DroolsKIEModuleModel> ruleEngineBootstrap)
void	setSuspendResumeTaskManager(SuspendResumeTaskManager suspendResumeTaskManager)
void	setTaskContext(TaskContext taskContext)
protected void	setUp()
<T> java.util.List<java.util.List<T>>	splitListByThreads(java.util.List<T> list, int numberOfThreads)
protected void	startWorkers(java.util.Set<java.lang.Thread> workers)
protected void	writeKModuleXML(KieModuleModel module, KieFileSystem kfs)
void	writePomXML(ReleaseId releaseId, KieFileSystem kfs)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRulePublishingSpliterator

public DefaultRulePublishingSpliterator()

Method Detail

publishRulesAsync

public RulePublishingFuture publishRulesAsync(KieModuleModel kieModuleModel,
                                              ReleaseId containerReleaseId,
                                              java.util.List<java.lang.String> ruleUuids,
                                              KIEModuleCacheBuilder cache)

Description copied from interface: RulePublishingSpliterator

split and compile multiple rules in parallel

Specified by:

publishRulesAsync in interface RulePublishingSpliterator

Parameters:

kieModuleModel - instance of KieModuleModel

containerReleaseId - Kie container release id ReleaseId

ruleUuids - a list of rule uuids

cache - instance of KIEModuleCacheBuilder

Returns:

instance of RulePublishingFuture

setUp

@PostConstruct
protected void setUp()

splitListByThreads

public <T> java.util.List<java.util.List<T>> splitListByThreads(java.util.List<T> list,
                                                                int numberOfThreads)

createNewWorker

protected java.lang.Thread createNewWorker(java.util.List<KieBuilder> kieBuilders,
                                           KieModuleModel kieModuleModel,
                                           ReleaseId releaseId,
                                           java.util.List<java.lang.String> ruleUuids,
                                           java.util.List<RuleEngineActionResult> ruleEngineActionResults,
                                           KIEModuleCacheBuilder cache)

startWorkers

protected void startWorkers(java.util.Set<java.lang.Thread> workers)

addRulesBuilder

protected RuleEngineActionResult addRulesBuilder(java.util.List<KieBuilder> kieBuilders,
                                                 KieModuleModel kieModuleModel,
                                                 ReleaseId releaseId,
                                                 java.util.List<java.lang.String> ruleUuids,
                                                 KIEModuleCacheBuilder cache)

createKieBuilderErrorResult

protected Results createKieBuilderErrorResult(DroolsRuleModel rule,
                                              java.lang.Exception e)

writeKModuleXML

protected void writeKModuleXML(KieModuleModel module,
                               KieFileSystem kfs)

writePomXML

public void writePomXML(ReleaseId releaseId,
                        KieFileSystem kfs)

createNewResult

protected RuleEngineActionResult createNewResult(Results results)

addNewResultItemOf

protected ResultItem addNewResultItemOf(RuleEngineActionResult result,
                                        MessageLevel messageLevel,
                                        java.lang.String message)

getKieServices

protected KieServices getKieServices()

getEngineRuleDao

protected EngineRuleDao getEngineRuleDao()

getTaskContext

protected TaskContext getTaskContext()

setTaskContext

public void setTaskContext(TaskContext taskContext)

setEngineRuleDao

public void setEngineRuleDao(EngineRuleDao engineRuleDao)

getRuleEngineBootstrap

protected RuleEngineBootstrap<KieServices,KieContainer,DroolsKIEModuleModel> getRuleEngineBootstrap()

setRuleEngineBootstrap

public void setRuleEngineBootstrap(RuleEngineBootstrap<KieServices,KieContainer,DroolsKIEModuleModel> ruleEngineBootstrap)

getSuspendResumeTaskManager

protected SuspendResumeTaskManager getSuspendResumeTaskManager()

setSuspendResumeTaskManager

public void setSuspendResumeTaskManager(SuspendResumeTaskManager suspendResumeTaskManager)