de.hybris.platform.ruleengine.init.impl

Class DefaultRuleEngineContainerRegistry

java.lang.Object

de.hybris.platform.ruleengine.init.impl.DefaultRuleEngineContainerRegistry

All Implemented Interfaces:

RuleEngineContainerRegistry<ReleaseId,KieContainer>

public class DefaultRuleEngineContainerRegistry
extends java.lang.Object
implements RuleEngineContainerRegistry<ReleaseId,KieContainer>

Default implementation of RuleEngineContainerRegistry interface, base on Drools

Constructor Summary

Constructors

Constructor and Description
DefaultRuleEngineContainerRegistry()

Method Summary

Modifier and Type	Method and Description
KieContainer	getActiveContainer(ReleaseId releaseId) Retrieve knowledgebase container reference, identified fy release id
protected ConcurrentMapFactory	getConcurrentMapFactory()
protected java.util.concurrent.locks.Lock	getReadLock()
protected java.util.concurrent.locks.ReadWriteLock	getReadWriteLock()
protected java.util.concurrent.locks.Lock	getWriteLock()
boolean	isLockedForReading() Check if the registry is locked for reading
boolean	isLockedForWriting() Check if the registry is locked for writing
void	lockReadingRegistry() lock or unlock registry for reading operations
void	lockWritingRegistry() lock or unlock registry for writing operations
java.util.Optional<ReleaseId>	lookupForDeployedRelease(java.lang.String... releaseTokens) Lookup for a deployed knowledgebase container release id by partial release id tokens (e.g.
KieContainer	removeActiveContainer(ReleaseId releaseHolder) Remove knowledgebase container identified by release id
void	setActiveContainer(ReleaseId releaseId, KieContainer rulesContainer) Adds another active container, identified by release, to a repository
void	setConcurrentMapFactory(ConcurrentMapFactory concurrentMapFactory)
void	setup()
void	unlockReadingRegistry() unlock or unlock registry for reading operations
void	unlockWritingRegistry() unlock or unlock registry for writing operations

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRuleEngineContainerRegistry

public DefaultRuleEngineContainerRegistry()

Method Detail

setActiveContainer

public void setActiveContainer(ReleaseId releaseId,
                               KieContainer rulesContainer)

Description copied from interface: RuleEngineContainerRegistry

Adds another active container, identified by release, to a repository

Specified by:

setActiveContainer in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

Parameters:

releaseId - knowledgebase container module release identifier

rulesContainer - knowledgebase container instance

getActiveContainer

public KieContainer getActiveContainer(ReleaseId releaseId)

Description copied from interface: RuleEngineContainerRegistry

Retrieve knowledgebase container reference, identified fy release id

Specified by:

getActiveContainer in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

Parameters:

releaseId - knowledgebase container module release identifier

Returns:

knowledgebase container instance

lookupForDeployedRelease

public java.util.Optional<ReleaseId> lookupForDeployedRelease(java.lang.String... releaseTokens)

Description copied from interface: RuleEngineContainerRegistry

Lookup for a deployed knowledgebase container release id by partial release id tokens (e.g. group id and artifact id)

Specified by:

lookupForDeployedRelease in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

Parameters:

releaseTokens - knowledgebase container module release identifier

Returns:

optional of container release id

removeActiveContainer

public KieContainer removeActiveContainer(ReleaseId releaseHolder)

Description copied from interface: RuleEngineContainerRegistry

Remove knowledgebase container identified by release id

Specified by:

removeActiveContainer in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

Parameters:

releaseHolder - knowledgebase container module release identifier

Returns:

removed knowledge base container instance, null if not found

lockReadingRegistry

public void lockReadingRegistry()

Description copied from interface: RuleEngineContainerRegistry

lock or unlock registry for reading operations

Specified by:

lockReadingRegistry in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

unlockReadingRegistry

public void unlockReadingRegistry()

Description copied from interface: RuleEngineContainerRegistry

unlock or unlock registry for reading operations

Specified by:

unlockReadingRegistry in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

lockWritingRegistry

public void lockWritingRegistry()

Description copied from interface: RuleEngineContainerRegistry

lock or unlock registry for writing operations

Specified by:

lockWritingRegistry in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

unlockWritingRegistry

public void unlockWritingRegistry()

Description copied from interface: RuleEngineContainerRegistry

unlock or unlock registry for writing operations

Specified by:

unlockWritingRegistry in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

isLockedForReading

public boolean isLockedForReading()

Description copied from interface: RuleEngineContainerRegistry

Check if the registry is locked for reading

Specified by:

isLockedForReading in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

Returns:

true if the registry is in the state locked for reading

isLockedForWriting

public boolean isLockedForWriting()

Description copied from interface: RuleEngineContainerRegistry

Check if the registry is locked for writing

Specified by:

isLockedForWriting in interface RuleEngineContainerRegistry<ReleaseId,KieContainer>

Returns:

true if the registry is in the state locked for writing

setup

@PostConstruct
public void setup()

getConcurrentMapFactory

protected ConcurrentMapFactory getConcurrentMapFactory()

setConcurrentMapFactory

public void setConcurrentMapFactory(ConcurrentMapFactory concurrentMapFactory)

getReadWriteLock

protected java.util.concurrent.locks.ReadWriteLock getReadWriteLock()

getReadLock

protected java.util.concurrent.locks.Lock getReadLock()

getWriteLock

protected java.util.concurrent.locks.Lock getWriteLock()