Package de.hybris.platform.ruleengine.init.impl

Class DefaultRuleEngineKieModuleSwapper

java.lang.Object

de.hybris.platform.ruleengine.init.impl.DefaultRuleEngineKieModuleSwapper

All Implemented Interfaces:

RuleEngineKieModuleSwapper

public class DefaultRuleEngineKieModuleSwapper
extends Object
implements RuleEngineKieModuleSwapper

Default (drools-based) implementation of the RuleEngineKieModuleSwapper interface

Field Summary

Fields

Modifier and Type	Field	Description
static final String	WORKER_PRE_DESTROY_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
DefaultRuleEngineKieModuleSwapper()

Method Summary

Modifier and Type	Method	Description
String	activateKieModule(DroolsKIEModuleModel module)	Updates the instance of DroolsKIEModuleModel with information about affectively deployed ReleaseId version
void	addKieBase(org.kie.api.builder.model.KieModuleModel module, DroolsKIEBaseModel base)	Adds new KieBaseModel to a KieModuleModel with all rules
void	addKieBase(org.kie.api.builder.model.KieModuleModel module, org.kie.api.builder.KieFileSystem kfs, DroolsKIEBaseModel base, KIEModuleCacheBuilder cache)	Adds new KieBaseModel to a KieModuleModel with all rules
void	addKieSession(org.kie.api.builder.model.KieBaseModel base, DroolsKIESessionModel session)	Adds instance of new KieSessionModel to KieBaseModel
protected ResultItem	addNewResultItemOf(RuleEngineActionResult result, MessageLevel messageLevel, String message)
void	addRules(org.kie.api.builder.KieFileSystem kfs, DroolsKIEBaseModel base, KIEModuleCacheBuilder cache)	Adds rules from a given DroolsKIEBaseModel to KieFileSystem
void	addRulesToCache(DroolsKIEBaseModel base, KIEModuleCacheBuilder cache)	Add cacheable data of rules of the latest versions belonging to the KieBase into the cache.
void	beforeDestroy()	This method to be called by containers (like spring container) as destroy method
protected org.drools.compiler.kie.builder.impl.MemoryKieModule	cloneForIncrementalCompilation(org.drools.compiler.kie.builder.impl.MemoryKieModule origKieModule, org.kie.api.builder.ReleaseId releaseId, org.kie.api.builder.model.KieModuleModel kModuleModel)	Method creates the clone of the KieModule, having the specified ReleaseId.
protected void	completeWithFailure(org.kie.api.builder.ReleaseId releaseId, RuleEngineActionResult result, KieContainerListener listener)
protected void	copyChanges(org.drools.compiler.kie.builder.impl.MemoryKieModule trgKieModule, org.drools.compiler.kie.builder.impl.MemoryKieModule srcKieModule)
org.apache.commons.lang3.tuple.Pair<org.kie.api.builder.KieModule,KIEModuleCacheBuilder>	createKieModule(DroolsKIEModuleModel module, RuleEngineActionResult result)	Creates the new instance of KieModule, based on information contained in DroolsKIEModuleModel
protected org.apache.commons.lang3.tuple.Pair<org.kie.api.builder.KieModule,KIEModuleCacheBuilder>	createKieModule(DroolsKIEModuleModel module, RuleEngineActionResult result, boolean enableIncrementalUpdate)
protected void	deleteRulesFromKieModule(org.drools.compiler.kie.builder.impl.MemoryKieModule kieModule, Collection<DroolsRuleModel> rules)	Removes the specified collection of DroolsRuleModel rules from KieModule
protected List<org.kie.api.builder.KieBuilder>	deployRules(DroolsKIEModuleModel module, org.kie.api.builder.model.KieModuleModel kieModuleModel, DroolsKIEBaseModel kieBase, KIEModuleCacheBuilder cache)
protected void	deployRulesIncrementally(org.kie.api.builder.ReleaseId releaseId, org.kie.api.builder.model.KieModuleModel kieModuleModel, org.kie.api.builder.KieModule kieModule, Collection<DroolsRuleModel> rulesToAdd, Collection<DroolsRuleModel> rulesToRemove, RuleEngineActionResult result)	Deploy incrementally the rule engine updates.
protected <R extends D, D extends AbstractRuleEngineRuleModel> Set<R>	filterByBiggestVersion(Collection<D> rulesForVersion)
protected ConcurrentMapFactory	getConcurrentMapFactory()
protected ConfigurationService	getConfigurationService()
protected ContentMatchRulesFilter	getContentMatchRulesFilter()
protected Tenant	getCurrentTenant()
Optional<org.kie.api.builder.ReleaseId>	getDeployedReleaseId(DroolsKIEModuleModel module, String deployedMvnVersion)	Returns (optional) ReleaseId for a deployed version of the KieModuleModel
protected EngineRuleDao	getEngineRuleDao()
protected IncrementalRuleEngineUpdateStrategy	getIncrementalRuleEngineUpdateStrategy()
protected InitializeMode	getInitializeMode(ExecutionContext executionContext)
protected KieModuleService	getKieModuleService()
protected org.kie.api.KieServices	getKieServices()
protected ModelService	getModelService()
protected String	getNextWorkerName()
org.kie.api.builder.ReleaseId	getReleaseId(DroolsKIEModuleModel module)	Creates the new instance of ReleaseId based on DroolsKIEModuleModel
protected RuleEngineBootstrap<org.kie.api.KieServices,org.kie.api.runtime.KieContainer,DroolsKIEModuleModel>	getRuleEngineBootstrap()
protected RuleEngineCacheService	getRuleEngineCacheService()
protected RulePublishingSpliterator	getRulePublishingSpliterator()
protected RulesModuleDao	getRulesModuleDao()
protected SuspendResumeTaskManager	getSuspendResumeTaskManager()
protected ThreadFactory	getTenantAwareThreadFactory()
protected long	getWorkerPreDestroyTimeout()
org.kie.api.runtime.KieContainer	initializeNewKieContainer(DroolsKIEModuleModel module, org.kie.api.builder.KieModule kieModule, RuleEngineActionResult result)	Creates the new instance of KieContainer for a given KieModule
protected void	initializeNewModule(DroolsKIEModuleModel module, KieContainerListener listener, boolean enableIncrementalUpdates, RuleEngineActionResult result)
protected boolean	isInitialEngineStartup(org.kie.api.builder.ReleaseId releaseId, String newDeployedMvnVersion)
protected boolean	isRuleValid(AbstractRuleEngineRuleModel rule)
protected void	mergeFileSystemToKieModule(org.drools.compiler.kie.builder.impl.MemoryKieModule partialKieModule, org.drools.compiler.compiler.io.memory.MemoryFileSystem mainMemoryFileSystem)
protected org.kie.api.builder.KieModule	mergePartialKieModules(org.kie.api.builder.ReleaseId releaseId, org.kie.api.builder.model.KieModuleModel kieModuleModel, List<org.kie.api.builder.KieBuilder> kieBuilders)
protected org.kie.api.builder.KieModule	mergePartialKieModules(org.kie.api.builder.ReleaseId releaseId, org.kie.api.builder.model.KieModuleModel kieModuleModel, org.kie.api.builder.KieModule partialKieModule)
protected void	newKieModule(DroolsKIEModuleModel module, KieContainerListener listener, boolean enableIncrementalUpdates, RuleEngineActionResult result)
protected Object	onSwapFailed(Throwable t, RuleEngineActionResult result, Supplier<Object> resetFlagSupplier)
protected Optional<org.apache.commons.lang3.tuple.Pair<Collection<DroolsRuleModel>,Collection<DroolsRuleModel>>>	prepareIncrementalUpdate(org.kie.api.builder.ReleaseId releaseId, DroolsKIEBaseModel kieBase)	Given the ReleaseId of the deployed KieModule the method returns the tuple consisting of rules to add/update and rules to delete.
protected void	registerWorker(String moduleName, Thread worker)
boolean	removeKieModuleIfPresent(org.kie.api.builder.ReleaseId releaseId, RuleEngineActionResult result)	Tries to remove the KieModule with given ReleaseId from KieRepository
boolean	removeOldKieModuleIfPresent(RuleEngineActionResult result)	Tries to remove the old KieModule from KieRepository
protected boolean	restoreKieModule(DroolsKIEModuleModel module, KieContainerListener listener, RuleEngineActionResult result)
void	setConcurrentMapFactory(ConcurrentMapFactory concurrentMapFactory)
void	setConfigurationService(ConfigurationService configurationService)
void	setContentMatchRulesFilter(ContentMatchRulesFilter contentMatchRulesFilter)
void	setCurrentTenant(Tenant currentTenant)
void	setEngineRuleDao(EngineRuleDao engineRuleDao)
void	setIncrementalRuleEngineUpdateStrategy(IncrementalRuleEngineUpdateStrategy incrementalRuleEngineUpdateStrategy)
void	setKieModuleService(KieModuleService kieModuleService)
protected void	setKieServices(org.kie.api.KieServices kieServices)
void	setModelService(ModelService modelService)
void	setRuleEngineBootstrap(RuleEngineBootstrap<org.kie.api.KieServices,org.kie.api.runtime.KieContainer,DroolsKIEModuleModel> ruleEngineBootstrap)
void	setRuleEngineCacheService(RuleEngineCacheService ruleEngineCacheService)
void	setRulePublishingSpliterator(RulePublishingSpliterator rulePublishingSpliterator)
void	setRulesModuleDao(RulesModuleDao rulesModuleDao)
void	setSuspendResumeTaskManager(SuspendResumeTaskManager suspendResumeTaskManager)
void	setTenantAwareThreadFactory(ThreadFactory tenantAwareThreadFactory)
void	setup()
void	setUpKieServices()	Initializes the KieServices instance
List<Object>	switchKieModule(DroolsKIEModuleModel module, KieContainerListener listener, LinkedList<Supplier<Object>> postTaskList, boolean enableIncrementalUpdate, RuleEngineActionResult result)	Swaps synchroneously to a new KieModule.
void	switchKieModuleAsync(String moduleName, KieContainerListener listener, List<Object> resultsAccumulator, Supplier<Object> resetFlagSupplier, List<Supplier<Object>> postTaskList, boolean enableIncrementalUpdate, RuleEngineActionResult result)	Swaps asynchroneously to a new KieModule.
protected Runnable	switchKieModuleRunnableTask(String moduleName, KieContainerListener listener, List<Object> resultsAccumulator, Supplier<Object> resetFlagSupplier, List<Supplier<Object>> postTaskList, boolean enableIncrementalUpdate, RuleEngineActionResult result)
protected void	verifyErrors(RuleEngineActionResult result, List<org.kie.api.builder.Message> messages)
void	waitForSwappingToFinish()	Block until the whole swapping task/tasks are finished
protected void	waitForSwappingToFinish(String moduleName)
protected void	waitWhileWorkerIsRunning(Thread worker)
void	writeKModuleXML(org.kie.api.builder.model.KieModuleModel module, org.kie.api.builder.KieFileSystem kfs)	Creates the XML representation of KieModuleModel and writes it to KieFileSystem
void	writePomXML(DroolsKIEModuleModel module, org.kie.api.builder.KieFileSystem kfs)	Write the building POM XML to KieFileSystem
protected void	writeRulesToKieFileSystem(org.kie.api.builder.KieFileSystem kfs, Collection<DroolsRuleModel> rules)

Methods inherited from class java.lang.Object

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

Field Details

WORKER_PRE_DESTROY_TIMEOUT

public static final String WORKER_PRE_DESTROY_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

DefaultRuleEngineKieModuleSwapper

public DefaultRuleEngineKieModuleSwapper()

Method Details

switchKieModule

public List<Object> switchKieModule(DroolsKIEModuleModel module,
 KieContainerListener listener,
 LinkedList<Supplier<Object>> postTaskList,
 boolean enableIncrementalUpdate,
 RuleEngineActionResult result)

Description copied from interface: RuleEngineKieModuleSwapper

Swaps synchroneously to a new KieModule. It's a blocking call

Specified by:

switchKieModule in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of the AbstractRulesModuleModel module

listener - instance of KieContainerListener that fires when the switch of Kie Container is complete

postTaskList - chain of post-task operations incapsulated as a linked list of Supplier instances

enableIncrementalUpdate - flag, if true, enables for incremental updates of the rule engine kie module

result - instance of RuleEngineActionResult to be used in cluster nodes notification

Returns:

the list that will contain the method execution results including the post-tasks

switchKieModuleAsync

public void switchKieModuleAsync(String moduleName,
 KieContainerListener listener,
 List<Object> resultsAccumulator,
 Supplier<Object> resetFlagSupplier,
 List<Supplier<Object>> postTaskList,
 boolean enableIncrementalUpdate,
 RuleEngineActionResult result)

Description copied from interface: RuleEngineKieModuleSwapper

Swaps asynchroneously to a new KieModule. It's a non-blocking call

Specified by:

switchKieModuleAsync in interface RuleEngineKieModuleSwapper

Parameters:

moduleName - kie module name

listener - instance of KieContainerListener that fires when the switch of Kie Container is complete

resultsAccumulator - the list that will contain the method execution results including the post-tasks

resetFlagSupplier - the task to perform after the sync call finishes the task (whether it was successfull or not )

postTaskList - chain of post-task operations incapsulated as a linked list of Supplier instances

enableIncrementalUpdate - flag, if true, enables for incremental updates of the rule engine kie module

result - instance of RuleEngineActionResult to be used in cluster nodes notification

waitForSwappingToFinish

public void waitForSwappingToFinish()

Description copied from interface: RuleEngineKieModuleSwapper

Block until the whole swapping task/tasks are finished

Specified by:

waitForSwappingToFinish in interface RuleEngineKieModuleSwapper

waitForSwappingToFinish

protected void waitForSwappingToFinish(String moduleName)

getNextWorkerName

protected String getNextWorkerName()

waitWhileWorkerIsRunning

protected void waitWhileWorkerIsRunning(Thread worker)

beforeDestroy

public void beforeDestroy()

This method to be called by containers (like spring container) as destroy method

writeKModuleXML

public void writeKModuleXML(org.kie.api.builder.model.KieModuleModel module,
 org.kie.api.builder.KieFileSystem kfs)

Description copied from interface: RuleEngineKieModuleSwapper

Creates the XML representation of KieModuleModel and writes it to KieFileSystem

Specified by:

writeKModuleXML in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of KieModuleModel

kfs - instance of KieFileSystem

writePomXML

public void writePomXML(DroolsKIEModuleModel module,
 org.kie.api.builder.KieFileSystem kfs)

Description copied from interface: RuleEngineKieModuleSwapper

Write the building POM XML to KieFileSystem

Specified by:

writePomXML in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of DroolsKIEModuleModel to be used for ReleaseId creation

kfs - instance of KieFileSystem

getReleaseId

public org.kie.api.builder.ReleaseId getReleaseId(DroolsKIEModuleModel module)

Description copied from interface: RuleEngineKieModuleSwapper

Creates the new instance of ReleaseId based on DroolsKIEModuleModel

Specified by:

getReleaseId in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of DroolsKIEModuleModel

Returns:

newly created ReleaseId

createKieModule

public org.apache.commons.lang3.tuple.Pair<org.kie.api.builder.KieModule,KIEModuleCacheBuilder> createKieModule(DroolsKIEModuleModel module,
 RuleEngineActionResult result)

Description copied from interface: RuleEngineKieModuleSwapper

Creates the new instance of KieModule, based on information contained in DroolsKIEModuleModel

Specified by:

createKieModule in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of DroolsKIEModuleModel

result - instance of RuleEngineActionResult to be used in cluster nodes notification

Returns:

pair of the newly created instance of KieModule and the corresponding caching structure for the created module

createKieModule

protected org.apache.commons.lang3.tuple.Pair<org.kie.api.builder.KieModule,KIEModuleCacheBuilder> createKieModule(DroolsKIEModuleModel module,
 RuleEngineActionResult result,
 boolean enableIncrementalUpdate)

copyChanges

protected void copyChanges(org.drools.compiler.kie.builder.impl.MemoryKieModule trgKieModule,
 org.drools.compiler.kie.builder.impl.MemoryKieModule srcKieModule)

cloneForIncrementalCompilation

protected org.drools.compiler.kie.builder.impl.MemoryKieModule cloneForIncrementalCompilation(org.drools.compiler.kie.builder.impl.MemoryKieModule origKieModule,
 org.kie.api.builder.ReleaseId releaseId,
 org.kie.api.builder.model.KieModuleModel kModuleModel)

Method creates the clone of the KieModule, having the specified ReleaseId. It creates the new instance of MemoryKieModule with given ReleaseId, KieModuleModel and new instance of MemoryFileSystem, copying from original KieModule all the relevant information (including file system content). (The #clone.mark(); is used to reset the map of modified files since last mark).

Parameters:

origKieModule - The instance of MemoryKieModule to clone

releaseId - The new ReleaseId for a clone MemoryKieModule

kModuleModel - instance of new KieModuleModel for a clone KieModule

Returns:

clone of MemoryKieModule with given ReleaseId

prepareIncrementalUpdate

protected Optional<org.apache.commons.lang3.tuple.Pair<Collection<DroolsRuleModel>,Collection<DroolsRuleModel>>> prepareIncrementalUpdate(org.kie.api.builder.ReleaseId releaseId,
 DroolsKIEBaseModel kieBase)

Given the ReleaseId of the deployed KieModule the method returns the tuple consisting of rules to add/update and rules to delete. Before returning the tuple the method applies the strategy to decide whether the incremental update is applicable. If it is not applicable the empty Optional is returned

Parameters:

releaseId - ReleaseId of the currently deployed kie module

kieBase - DroolsKIEBaseModel containing the set of rules to deploy

Returns:

a Pair containing the rules to add/update (left-hand-side) and the rules to delete (right-hand-side)

deployRulesIncrementally

protected void deployRulesIncrementally(org.kie.api.builder.ReleaseId releaseId,
 org.kie.api.builder.model.KieModuleModel kieModuleModel,
 org.kie.api.builder.KieModule kieModule,
 Collection<DroolsRuleModel> rulesToAdd,
 Collection<DroolsRuleModel> rulesToRemove,
 RuleEngineActionResult result)

Deploy incrementally the rule engine updates. It accepts the new ReleaseId, new KieModuleModel, the clone MemoryKieModule and based on the collections of rules to add/update and delete, applies the incremental rule engine updates. In order to add/update the rule engine the new instance of KieBuilder is created. After the proper KieBuilderSet with updates is created, the KieBuilderSet.#build() method is called. if the update was successful, the updated information is copied from "incremental" KieModule to the clone KieModule (method copyChanges(MemoryKieModule, MemoryKieModule))

Parameters:

releaseId - new ReleaseId

kieModuleModel - new KieModuleModel

kieModule - clone KieModule

rulesToAdd - a collection of DroolsRuleModel rules to add/update

rulesToRemove - a collection of DroolsRuleModel rules to remove

result - instance of RuleEngineActionResult accumulating the results of deploy

verifyErrors

protected void verifyErrors(RuleEngineActionResult result,
 List<org.kie.api.builder.Message> messages)

mergePartialKieModules

protected org.kie.api.builder.KieModule mergePartialKieModules(org.kie.api.builder.ReleaseId releaseId,
 org.kie.api.builder.model.KieModuleModel kieModuleModel,
 org.kie.api.builder.KieModule partialKieModule)

mergeFileSystemToKieModule

protected void mergeFileSystemToKieModule(org.drools.compiler.kie.builder.impl.MemoryKieModule partialKieModule,
 org.drools.compiler.compiler.io.memory.MemoryFileSystem mainMemoryFileSystem)

mergePartialKieModules

protected org.kie.api.builder.KieModule mergePartialKieModules(org.kie.api.builder.ReleaseId releaseId,
 org.kie.api.builder.model.KieModuleModel kieModuleModel,
 List<org.kie.api.builder.KieBuilder> kieBuilders)

addKieBase

public void addKieBase(org.kie.api.builder.model.KieModuleModel module,
 org.kie.api.builder.KieFileSystem kfs,
 DroolsKIEBaseModel base,
 KIEModuleCacheBuilder cache)

Description copied from interface: RuleEngineKieModuleSwapper

Adds new KieBaseModel to a KieModuleModel with all rules

Specified by:

addKieBase in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of KieModuleModel to add the KieBaseModel to

kfs - instance of KieFileSystem

base - instance of DroolsKIEBaseModel that keeps the information for a KieBaseModel to be created

cache - the caching structure for the module being initialized

addKieBase

public void addKieBase(org.kie.api.builder.model.KieModuleModel module,
 DroolsKIEBaseModel base)

Description copied from interface: RuleEngineKieModuleSwapper

Adds new KieBaseModel to a KieModuleModel with all rules

Specified by:

addKieBase in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of KieModuleModel to add the KieBaseModel to

base - instance of DroolsKIEBaseModel that keeps the information for a KieBaseModel to be created

addKieSession

public void addKieSession(org.kie.api.builder.model.KieBaseModel base,
 DroolsKIESessionModel session)

Description copied from interface: RuleEngineKieModuleSwapper

Adds instance of new KieSessionModel to KieBaseModel

Specified by:

addKieSession in interface RuleEngineKieModuleSwapper

Parameters:

base - instance of KieBaseModel

session - instance of DroolsKIESessionModel containing the information for new KieSessionModel

activateKieModule

public String activateKieModule(DroolsKIEModuleModel module)

Description copied from interface: RuleEngineKieModuleSwapper

Updates the instance of DroolsKIEModuleModel with information about affectively deployed ReleaseId version

Specified by:

activateKieModule in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of DroolsKIEModuleModel

Returns:

version of deployed ReleaseId

removeKieModuleIfPresent

public boolean removeKieModuleIfPresent(org.kie.api.builder.ReleaseId releaseId,
 RuleEngineActionResult result)

Description copied from interface: RuleEngineKieModuleSwapper

Tries to remove the KieModule with given ReleaseId from KieRepository

Specified by:

removeKieModuleIfPresent in interface RuleEngineKieModuleSwapper

Parameters:

releaseId - the instance of ReleaseId corresponding to a KieModule to be removed

result - instance of RuleEngineActionResult to be used in cluster nodes notification removal

Returns:

true if the module was found and removed, false otherwise

removeOldKieModuleIfPresent

public boolean removeOldKieModuleIfPresent(RuleEngineActionResult result)

Description copied from interface: RuleEngineKieModuleSwapper

Tries to remove the old KieModule from KieRepository

Specified by:

removeOldKieModuleIfPresent in interface RuleEngineKieModuleSwapper

Parameters:

result - instance of RuleEngineActionResult to be used in cluster nodes notification removal

Returns:

true if the module was found and removed, false otherwise

addRules

public void addRules(org.kie.api.builder.KieFileSystem kfs,
 DroolsKIEBaseModel base,
 KIEModuleCacheBuilder cache)

Description copied from interface: RuleEngineKieModuleSwapper

Adds rules from a given DroolsKIEBaseModel to KieFileSystem

Specified by:

addRules in interface RuleEngineKieModuleSwapper

Parameters:

kfs - instance of KieFileSystem

base - instance of DroolsKIEBaseModel containing the reference to the rules to publish

cache - the caching structure for the module being initialized

filterByBiggestVersion

protected <R extends D,
D extends AbstractRuleEngineRuleModel>
Set<R> filterByBiggestVersion(Collection<D> rulesForVersion)

isRuleValid

protected boolean isRuleValid(AbstractRuleEngineRuleModel rule)

writeRulesToKieFileSystem

protected void writeRulesToKieFileSystem(org.kie.api.builder.KieFileSystem kfs,
 Collection<DroolsRuleModel> rules)

deleteRulesFromKieModule

protected void deleteRulesFromKieModule(org.drools.compiler.kie.builder.impl.MemoryKieModule kieModule,
 Collection<DroolsRuleModel> rules)

Removes the specified collection of DroolsRuleModel rules from KieModule

Parameters:

kieModule - the instance of clone KieModule to remove rules from

rules - Collection of DroolsRuleModel rules to delete

getDeployedReleaseId

public Optional<org.kie.api.builder.ReleaseId> getDeployedReleaseId(DroolsKIEModuleModel module,
 String deployedMvnVersion)

Description copied from interface: RuleEngineKieModuleSwapper

Returns (optional) ReleaseId for a deployed version of the KieModuleModel

Specified by:

getDeployedReleaseId in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of DroolsKIEModuleModel

deployedMvnVersion - currently deployed releaseId version of the Kie Module, if known

Returns:

instance of Optional.of(ReleaseId) if the ReleaseId could be created, Optional.empty() otherwise

setUpKieServices

public void setUpKieServices()

Description copied from interface: RuleEngineKieModuleSwapper

Initializes the KieServices instance

Specified by:

setUpKieServices in interface RuleEngineKieModuleSwapper

setup

@PostConstruct
public void setup()

deployRules

protected List<org.kie.api.builder.KieBuilder> deployRules(DroolsKIEModuleModel module,
 org.kie.api.builder.model.KieModuleModel kieModuleModel,
 DroolsKIEBaseModel kieBase,
 KIEModuleCacheBuilder cache)

initializeNewKieContainer

public org.kie.api.runtime.KieContainer initializeNewKieContainer(DroolsKIEModuleModel module,
 org.kie.api.builder.KieModule kieModule,
 RuleEngineActionResult result)

Description copied from interface: RuleEngineKieModuleSwapper

Creates the new instance of KieContainer for a given KieModule

Specified by:

initializeNewKieContainer in interface RuleEngineKieModuleSwapper

Parameters:

module - instance of DroolsKIEModuleModel

kieModule - instance of KieModule

result - instance of RuleEngineActionResult to be used in cluster nodes notification

Returns:

new KieContainer instance

initializeNewModule

protected void initializeNewModule(DroolsKIEModuleModel module,
 KieContainerListener listener,
 boolean enableIncrementalUpdates,
 RuleEngineActionResult result)

getInitializeMode

protected InitializeMode getInitializeMode(ExecutionContext executionContext)

restoreKieModule

protected boolean restoreKieModule(DroolsKIEModuleModel module,
 KieContainerListener listener,
 RuleEngineActionResult result)

newKieModule

protected void newKieModule(DroolsKIEModuleModel module,
 KieContainerListener listener,
 boolean enableIncrementalUpdates,
 RuleEngineActionResult result)

addRulesToCache

public void addRulesToCache(DroolsKIEBaseModel base,
 KIEModuleCacheBuilder cache)

Description copied from interface: RuleEngineKieModuleSwapper

Add cacheable data of rules of the latest versions belonging to the KieBase into the cache.

Specified by:

addRulesToCache in interface RuleEngineKieModuleSwapper

Parameters:

base - KieBase of the rules to be processed

cache - CacheBuilder to cache rule data

completeWithFailure

protected void completeWithFailure(org.kie.api.builder.ReleaseId releaseId,
 RuleEngineActionResult result,
 KieContainerListener listener)

addNewResultItemOf

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

registerWorker

protected void registerWorker(String moduleName,
 Thread worker)

switchKieModuleRunnableTask

protected Runnable switchKieModuleRunnableTask(String moduleName,
 KieContainerListener listener,
 List<Object> resultsAccumulator,
 Supplier<Object> resetFlagSupplier,
 List<Supplier<Object>> postTaskList,
 boolean enableIncrementalUpdate,
 RuleEngineActionResult result)

onSwapFailed

protected Object onSwapFailed(Throwable t,
 RuleEngineActionResult result,
 Supplier<Object> resetFlagSupplier)

isInitialEngineStartup

protected boolean isInitialEngineStartup(org.kie.api.builder.ReleaseId releaseId,
 String newDeployedMvnVersion)

getKieServices

protected org.kie.api.KieServices getKieServices()

setKieServices

protected void setKieServices(org.kie.api.KieServices kieServices)

getConfigurationService

protected ConfigurationService getConfigurationService()

setConfigurationService

public void setConfigurationService(ConfigurationService configurationService)

getCurrentTenant

protected Tenant getCurrentTenant()

setCurrentTenant

public void setCurrentTenant(Tenant currentTenant)

getTenantAwareThreadFactory

protected ThreadFactory getTenantAwareThreadFactory()

setTenantAwareThreadFactory

public void setTenantAwareThreadFactory(ThreadFactory tenantAwareThreadFactory)

getModelService

protected ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)

getRuleEngineCacheService

protected RuleEngineCacheService getRuleEngineCacheService()

setRuleEngineCacheService

public void setRuleEngineCacheService(RuleEngineCacheService ruleEngineCacheService)

getRulesModuleDao

protected RulesModuleDao getRulesModuleDao()

setRulesModuleDao

public void setRulesModuleDao(RulesModuleDao rulesModuleDao)

getConcurrentMapFactory

protected ConcurrentMapFactory getConcurrentMapFactory()

setConcurrentMapFactory

public void setConcurrentMapFactory(ConcurrentMapFactory concurrentMapFactory)

getRulePublishingSpliterator

protected RulePublishingSpliterator getRulePublishingSpliterator()

setRulePublishingSpliterator

public void setRulePublishingSpliterator(RulePublishingSpliterator rulePublishingSpliterator)

getContentMatchRulesFilter

protected ContentMatchRulesFilter getContentMatchRulesFilter()

setContentMatchRulesFilter

public void setContentMatchRulesFilter(ContentMatchRulesFilter contentMatchRulesFilter)

getIncrementalRuleEngineUpdateStrategy

protected IncrementalRuleEngineUpdateStrategy getIncrementalRuleEngineUpdateStrategy()

setIncrementalRuleEngineUpdateStrategy

public void setIncrementalRuleEngineUpdateStrategy(IncrementalRuleEngineUpdateStrategy incrementalRuleEngineUpdateStrategy)

getRuleEngineBootstrap

protected RuleEngineBootstrap<org.kie.api.KieServices,org.kie.api.runtime.KieContainer,DroolsKIEModuleModel> getRuleEngineBootstrap()

setRuleEngineBootstrap

public void setRuleEngineBootstrap(RuleEngineBootstrap<org.kie.api.KieServices,org.kie.api.runtime.KieContainer,DroolsKIEModuleModel> ruleEngineBootstrap)

getWorkerPreDestroyTimeout

protected long getWorkerPreDestroyTimeout()

getSuspendResumeTaskManager

protected SuspendResumeTaskManager getSuspendResumeTaskManager()

setSuspendResumeTaskManager

public void setSuspendResumeTaskManager(SuspendResumeTaskManager suspendResumeTaskManager)

getKieModuleService

protected KieModuleService getKieModuleService()

setKieModuleService

public void setKieModuleService(KieModuleService kieModuleService)

getEngineRuleDao

protected EngineRuleDao getEngineRuleDao()

setEngineRuleDao

public void setEngineRuleDao(EngineRuleDao engineRuleDao)