de.hybris.platform.ruleengine.init

Interface RuleEngineKieModuleSwapper

All Known Implementing Classes:

DefaultRuleEngineKieModuleSwapper

public interface RuleEngineKieModuleSwapper

Drools - specific interface incapsulating the logic of swapping to a new KieContainer during the RuleEngine initialization phase

Method Summary

Modifier and Type	Method and Description
String	activateKieModule(DroolsKIEModuleModel module) Updates the instance of DroolsKIEModuleModel with information about affectively deployed ReleaseId version
void	addKieBase(KieModuleModel module, KieFileSystem kfs, DroolsKIEBaseModel base, KIEModuleCacheBuilder cache) Adds new KieBaseModel to a KieModuleModel with all rules
void	addKieSession(KieBaseModel base, DroolsKIESessionModel session) Adds instance of new KieSessionModel to KieBaseModel
void	addRules(KieFileSystem kfs, DroolsKIEBaseModel base, KIEModuleCacheBuilder cache) Adds rules from a given DroolsKIEBaseModel to KieFileSystem
static MessageLevel	convertLevel(Message.Level level) converts a drools message Level to a MessageLevel.
<any>	createKieModule(DroolsKIEModuleModel module, RuleEngineActionResult result) Creates the new instance of KieModule, based on information contained in DroolsKIEModuleModel
Optional<ReleaseId>	getDeployedReleaseId(DroolsKIEModuleModel module, String deployedMvnVersion) Returns (optional) ReleaseId for a deployed version of the KieModuleModel
static EqualityBehaviorOption	getEqualityBehaviorOption(DroolsEqualityBehavior behavior) converts between hybris and drools equality behavior
static EventProcessingOption	getEventProcessingOption(DroolsEventProcessingMode eventProcessingMode) converts between hybris and drools event processing mode
ReleaseId	getReleaseId(DroolsKIEModuleModel module) Creates the new instance of ReleaseId based on DroolsKIEModuleModel
static KieSessionModel.KieSessionType	getSessionType(DroolsSessionType sessionType) converts between hybris and drools session type
boolean	removeKieModuleIfPresent(ReleaseId releaseId, RuleEngineActionResult result) Tries to remove the KieModule with given ReleaseId from org.kie.api.builder.KieRepository
void	setUpKieServices() Initializes the org.kie.api.KieServices instance
List<Object>	switchKieModule(DroolsKIEModuleModel module, RuleEngineActionResult result, KieContainerListener listener, LinkedList<Supplier<Object>> postTaskList) Swaps synchroneously to a new KieModule.
void	switchKieModuleAsync(String moduleName, RuleEngineActionResult result, KieContainerListener listener, List<Object> resultsAccumulator, LinkedList<Supplier<Object>> postTaskList) Swaps asynchroneously to a new KieModule.
void	waitForSwappingToFinish() Block until the whole swapping task/tasks are finished
void	writeKModuleXML(KieModuleModel module, KieFileSystem kfs) Creates the XML representation of KieModuleModel and writes it to KieFileSystem
void	writePomXML(DroolsKIEModuleModel module, KieFileSystem kfs) Write the building POM XML to KieFileSystem

Method Detail

switchKieModule

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

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

Parameters:

module - instance of the AbstractRulesModuleModel module

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

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

Returns:

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

switchKieModuleAsync

void switchKieModuleAsync(String moduleName,
                          RuleEngineActionResult result,
                          KieContainerListener listener,
                          List<Object> resultsAccumulator,
                          LinkedList<Supplier<Object>> postTaskList)

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

Parameters:

moduleName - kie module name

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

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

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

createKieModule

<any> createKieModule(DroolsKIEModuleModel module,
                      RuleEngineActionResult result)

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

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

addKieBase

void addKieBase(KieModuleModel module,
                KieFileSystem kfs,
                DroolsKIEBaseModel base,
                KIEModuleCacheBuilder cache)

Adds new KieBaseModel to a KieModuleModel with all rules

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

activateKieModule

String activateKieModule(DroolsKIEModuleModel module)

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

Parameters:

module - instance of DroolsKIEModuleModel

Returns:

version of deployed ReleaseId

removeKieModuleIfPresent

boolean removeKieModuleIfPresent(ReleaseId releaseId,
                                 RuleEngineActionResult result)

Tries to remove the KieModule with given ReleaseId from org.kie.api.builder.KieRepository

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

addKieSession

void addKieSession(KieBaseModel base,
                   DroolsKIESessionModel session)

Adds instance of new KieSessionModel to KieBaseModel

Parameters:

base - instance of KieBaseModel

session - instance of DroolsKIESessionModel containing the information for new KieSessionModel

addRules

void addRules(KieFileSystem kfs,
              DroolsKIEBaseModel base,
              KIEModuleCacheBuilder cache)

Adds rules from a given DroolsKIEBaseModel to KieFileSystem

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

writeKModuleXML

void writeKModuleXML(KieModuleModel module,
                     KieFileSystem kfs)

Creates the XML representation of KieModuleModel and writes it to KieFileSystem

Parameters:

module - instance of KieModuleModel

kfs - instance of KieFileSystem

writePomXML

void writePomXML(DroolsKIEModuleModel module,
                 KieFileSystem kfs)

Write the building POM XML to KieFileSystem

Parameters:

module - instance of DroolsKIEModuleModel to be used for ReleaseId creation

kfs - instance of KieFileSystem

getReleaseId

ReleaseId getReleaseId(DroolsKIEModuleModel module)

Creates the new instance of ReleaseId based on DroolsKIEModuleModel

Parameters:

module - instance of DroolsKIEModuleModel

Returns:

newly created ReleaseId

getDeployedReleaseId

Optional<ReleaseId> getDeployedReleaseId(DroolsKIEModuleModel module,
                                         String deployedMvnVersion)

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

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

void setUpKieServices()

Initializes the org.kie.api.KieServices instance

waitForSwappingToFinish

void waitForSwappingToFinish()

Block until the whole swapping task/tasks are finished

getSessionType

static KieSessionModel.KieSessionType getSessionType(DroolsSessionType sessionType)

converts between hybris and drools session type

getEqualityBehaviorOption

static EqualityBehaviorOption getEqualityBehaviorOption(DroolsEqualityBehavior behavior)

converts between hybris and drools equality behavior

getEventProcessingOption

static EventProcessingOption getEventProcessingOption(DroolsEventProcessingMode eventProcessingMode)

converts between hybris and drools event processing mode

convertLevel

static MessageLevel convertLevel(Message.Level level)

converts a drools message Level to a MessageLevel.