Package de.hybris.platform.ruleengine.drools.impl

Class DefaultKieSessionHelper<T>

java.lang.Object

de.hybris.platform.ruleengine.drools.impl.DefaultModuleReleaseIdAware

de.hybris.platform.ruleengine.drools.impl.DefaultKieSessionHelper<T>

All Implemented Interfaces:

KieSessionHelper<T>, ModuleReleaseIdAware

public class DefaultKieSessionHelper<T>
extends DefaultModuleReleaseIdAware
implements KieSessionHelper<T>

Default implementation of KieSessionHelper

Constructor Summary

Constructors

Constructor	Description
DefaultKieSessionHelper()

Method Summary

Modifier and Type	Method	Description
protected void	assertKieSessionClass(java.lang.Class<T> kieSessionClass)
protected void	assertSessionIsStateful(DroolsKIESessionModel kieSession)
protected void	assertSessionIsStateless(DroolsKIESessionModel kieSession)
protected RuleExecutionCountListener	createRuleExecutionCounterListener()
protected org.kie.api.runtime.KieSessionsPool	getKieContainerSessionsPool(org.kie.api.runtime.KieContainer kieContainer, boolean stateless)
protected int	getKieSessionPoolInitialCapacity()
protected java.util.Map<org.kie.api.runtime.KieContainer,org.kie.api.runtime.KieSessionsPool>	getKieSessionsPools()
protected java.lang.Class<? extends RuleExecutionCountListener>	getRuleExecutionCounterClass()
protected org.kie.api.runtime.KieSession	initializeKieSessionInternal(RuleEvaluationContext context, DroolsRuleEngineContextModel ruleEngineContext, org.kie.api.runtime.KieContainer kieContainer)
T	initializeSession(java.lang.Class<T> kieSessionClass, RuleEvaluationContext context, org.kie.api.runtime.KieContainer kieContainer)	given the RuleEvaluationContext and currently active instance of KieContainer, initializes the KieSessionHelper kie session for evaluation of rules
protected org.kie.api.runtime.StatelessKieSession	initializeStatelessKieSessionInternal(RuleEvaluationContext context, DroolsRuleEngineContextModel ruleEngineContext, org.kie.api.runtime.KieContainer kieContainer)
protected boolean	isKeepOnlyOneSessionPoolVersion()
protected boolean	isKieSessionPoolEnabled()
protected void	registerKieSessionListeners(RuleEvaluationContext context, org.kie.api.runtime.KieSession session, java.lang.Long maximumExecutions)
protected void	registerStatelessKieSessionListeners(RuleEvaluationContext context, org.kie.api.runtime.StatelessKieSession session, java.lang.Long maximumExecutions)
void	setKeepOnlyOneSessionPoolVersion(boolean keepOnlyOneSessionPoolVersion)
void	setKieSessionPoolEnabled(boolean kieSessionPoolEnabled)
void	setKieSessionPoolInitialCapacity(int kieSessionPoolInitialCapacity)
void	setRuleExecutionCounterClass(java.lang.Class<? extends RuleExecutionCountListener> ruleExecutionCounterClass)
void	shutdownKieSessionPools(java.lang.String moduleName, java.lang.String version)	removes all old kieContainers (same artifactId but other versions) after successful swapping
protected void	teardownSessionsPools()

Methods inherited from class de.hybris.platform.ruleengine.drools.impl.DefaultModuleReleaseIdAware

getDeployedKieModuleReleaseId, getDummyReleaseId, getRuleEngineKieModuleSwapper, setRuleEngineKieModuleSwapper, validateRuleEvaluationContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.hybris.platform.ruleengine.drools.ModuleReleaseIdAware

getDeployedKieModuleReleaseId

Constructor Detail

DefaultKieSessionHelper

public DefaultKieSessionHelper()

Method Detail

initializeSession

public T initializeSession(java.lang.Class<T> kieSessionClass,
                           RuleEvaluationContext context,
                           org.kie.api.runtime.KieContainer kieContainer)

Description copied from interface: KieSessionHelper

given the RuleEvaluationContext and currently active instance of KieContainer, initializes the KieSessionHelper kie session for evaluation of rules

Specified by:

initializeSession in interface KieSessionHelper<T>

Parameters:

kieSessionClass - implementation class of the Kie session (KieSession or StatelessKieSession)

context - instance of RuleEvaluationContext

kieContainer - currently active instance of KieContainer

Returns:

initialized instance of KieSession

initializeKieSessionInternal

protected org.kie.api.runtime.KieSession initializeKieSessionInternal(RuleEvaluationContext context,
                                                                      DroolsRuleEngineContextModel ruleEngineContext,
                                                                      org.kie.api.runtime.KieContainer kieContainer)

initializeStatelessKieSessionInternal

protected org.kie.api.runtime.StatelessKieSession initializeStatelessKieSessionInternal(RuleEvaluationContext context,
                                                                                        DroolsRuleEngineContextModel ruleEngineContext,
                                                                                        org.kie.api.runtime.KieContainer kieContainer)

assertKieSessionClass

protected void assertKieSessionClass(java.lang.Class<T> kieSessionClass)

assertSessionIsStateless

protected void assertSessionIsStateless(DroolsKIESessionModel kieSession)

assertSessionIsStateful

protected void assertSessionIsStateful(DroolsKIESessionModel kieSession)

registerKieSessionListeners

protected void registerKieSessionListeners(RuleEvaluationContext context,
                                           org.kie.api.runtime.KieSession session,
                                           java.lang.Long maximumExecutions)

registerStatelessKieSessionListeners

protected void registerStatelessKieSessionListeners(RuleEvaluationContext context,
                                                    org.kie.api.runtime.StatelessKieSession session,
                                                    java.lang.Long maximumExecutions)

createRuleExecutionCounterListener

protected RuleExecutionCountListener createRuleExecutionCounterListener()

teardownSessionsPools

@PreDestroy
protected void teardownSessionsPools()

getKieContainerSessionsPool

protected org.kie.api.runtime.KieSessionsPool getKieContainerSessionsPool(org.kie.api.runtime.KieContainer kieContainer,
                                                                          boolean stateless)

shutdownKieSessionPools

public void shutdownKieSessionPools(java.lang.String moduleName,
                                    java.lang.String version)

removes all old kieContainers (same artifactId but other versions) after successful swapping

Specified by:

shutdownKieSessionPools in interface KieSessionHelper<T>

Parameters:

moduleName - the rule module name

version - the rule module version

getRuleExecutionCounterClass

protected java.lang.Class<? extends RuleExecutionCountListener> getRuleExecutionCounterClass()

getKieSessionsPools

protected java.util.Map<org.kie.api.runtime.KieContainer,org.kie.api.runtime.KieSessionsPool> getKieSessionsPools()

setRuleExecutionCounterClass

public void setRuleExecutionCounterClass(java.lang.Class<? extends RuleExecutionCountListener> ruleExecutionCounterClass)

getKieSessionPoolInitialCapacity

protected int getKieSessionPoolInitialCapacity()

setKieSessionPoolInitialCapacity

public void setKieSessionPoolInitialCapacity(int kieSessionPoolInitialCapacity)

isKeepOnlyOneSessionPoolVersion

protected boolean isKeepOnlyOneSessionPoolVersion()

setKeepOnlyOneSessionPoolVersion

public void setKeepOnlyOneSessionPoolVersion(boolean keepOnlyOneSessionPoolVersion)

isKieSessionPoolEnabled

protected boolean isKieSessionPoolEnabled()

setKieSessionPoolEnabled

public void setKieSessionPoolEnabled(boolean kieSessionPoolEnabled)