de.hybris.platform.ruleengineservices.maintenance.impl

Class DefaultRuleCompilationContext

java.lang.Object

de.hybris.platform.ruleengineservices.maintenance.impl.DefaultRuleCompilationContext

All Implemented Interfaces:

TaskContext, RuleCompilationContext

public class DefaultRuleCompilationContext
extends java.lang.Object
implements RuleCompilationContext

Default implementation of the RuleCompilationContext interface

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	WORKER_PRE_DESTROY_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
DefaultRuleCompilationContext()

Method Summary

Modifier and Type	Method and Description
void	cleanup(java.lang.String moduleName) Clean up the context (usually called before the object destroy)
protected ConcurrentMapFactory	getConcurrentMapFactory()
protected ConfigurationService	getConfigurationService()
Tenant	getCurrentTenant() Get the currently active tenant
protected EventService	getEventService()
java.lang.Long	getNextRuleEngineRuleVersion(java.lang.String moduleName) get the next available rule version for the module
int	getNumberOfThreads() get the maximum number of threads to allocate for multi-thread execution
RuleCompilerService	getRuleCompilerService() get the instance of RuleCompilerService
protected RuleEngineSpliteratorStrategy	getRuleEngineSpliteratorStrategy()
protected RulesModuleDao	getRulesModuleDao()
SuspendResumeTaskManager	getSuspendResumeTaskManager() get the suspend/resume task manager
java.util.concurrent.ThreadFactory	getThreadFactory() get the thread factory to be used for creating the tenant-aware threads
java.lang.Long	getThreadTimeout() get the thread pre-destroy timeout
void	registerCompilationListeners(java.lang.String moduleName) register aplication listeners related to rule compilation process
java.util.concurrent.atomic.AtomicLong	resetRuleEngineRuleVersion(java.lang.String moduleName) Resets the compilation context version to the value associated with rules module
void	setConcurrentMapFactory(ConcurrentMapFactory concurrentMapFactory)
void	setConfigurationService(ConfigurationService configurationService)
void	setCurrentTenant(Tenant currentTenant)
void	setEventService(EventService eventService)
void	setRuleCompilerService(RuleCompilerService ruleCompilerService)
void	setRuleEngineSpliteratorStrategy(RuleEngineSpliteratorStrategy ruleEngineSpliteratorStrategy)
void	setRulesModuleDao(RulesModuleDao rulesModuleDao)
void	setSuspendResumeTaskManager(SuspendResumeTaskManager suspendResumeTaskManager)
void	setThreadFactory(java.util.concurrent.ThreadFactory threadFactory)
void	setUp()

Methods inherited from class java.lang.Object

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

Field Detail

WORKER_PRE_DESTROY_TIMEOUT

public static final java.lang.String WORKER_PRE_DESTROY_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

DefaultRuleCompilationContext

public DefaultRuleCompilationContext()

Method Detail

getCurrentTenant

public Tenant getCurrentTenant()

Description copied from interface: TaskContext

Get the currently active tenant

Specified by:

getCurrentTenant in interface TaskContext

Returns:

The active tenant

getThreadFactory

public java.util.concurrent.ThreadFactory getThreadFactory()

Description copied from interface: TaskContext

get the thread factory to be used for creating the tenant-aware threads

Specified by:

getThreadFactory in interface TaskContext

Returns:

the thread factory implementation

getRuleCompilerService

public RuleCompilerService getRuleCompilerService()

Description copied from interface: RuleCompilationContext

get the instance of RuleCompilerService

Specified by:

getRuleCompilerService in interface RuleCompilationContext

Returns:

instance of RuleCompilerService

getNumberOfThreads

public int getNumberOfThreads()

Description copied from interface: TaskContext

get the maximum number of threads to allocate for multi-thread execution

Specified by:

getNumberOfThreads in interface TaskContext

Returns:

number of threads

getThreadTimeout

public java.lang.Long getThreadTimeout()

Description copied from interface: TaskContext

get the thread pre-destroy timeout

Specified by:

getThreadTimeout in interface TaskContext

Returns:

number of milliseconds to wait before forcing the thread to join

resetRuleEngineRuleVersion

public java.util.concurrent.atomic.AtomicLong resetRuleEngineRuleVersion(java.lang.String moduleName)

Description copied from interface: RuleCompilationContext

Resets the compilation context version to the value associated with rules module

Specified by:

resetRuleEngineRuleVersion in interface RuleCompilationContext

Parameters:

moduleName - the module name for the series of rules to compile

Returns:

the instance of AtomicLong keeping the module rules version

getNextRuleEngineRuleVersion

public java.lang.Long getNextRuleEngineRuleVersion(java.lang.String moduleName)

Description copied from interface: RuleCompilationContext

get the next available rule version for the module

Specified by:

getNextRuleEngineRuleVersion in interface RuleCompilationContext

Parameters:

moduleName - the module name for the series of rules to compile

Returns:

a version number

cleanup

public void cleanup(java.lang.String moduleName)

Description copied from interface: RuleCompilationContext

Clean up the context (usually called before the object destroy)

Specified by:

cleanup in interface RuleCompilationContext

Parameters:

moduleName - the rules module name to be monitored by listeners

registerCompilationListeners

public void registerCompilationListeners(java.lang.String moduleName)

Description copied from interface: RuleCompilationContext

register aplication listeners related to rule compilation process

Specified by:

registerCompilationListeners in interface RuleCompilationContext

Parameters:

moduleName - the rules module name to be monitored by listeners

setUp

@PostConstruct
public void setUp()

setCurrentTenant

public void setCurrentTenant(Tenant currentTenant)

setThreadFactory

public void setThreadFactory(java.util.concurrent.ThreadFactory threadFactory)

setRuleCompilerService

public void setRuleCompilerService(RuleCompilerService ruleCompilerService)

setConfigurationService

public void setConfigurationService(ConfigurationService configurationService)

getConfigurationService

protected ConfigurationService getConfigurationService()

getRuleEngineSpliteratorStrategy

protected RuleEngineSpliteratorStrategy getRuleEngineSpliteratorStrategy()

setRuleEngineSpliteratorStrategy

public void setRuleEngineSpliteratorStrategy(RuleEngineSpliteratorStrategy ruleEngineSpliteratorStrategy)

getRulesModuleDao

protected RulesModuleDao getRulesModuleDao()

setRulesModuleDao

public void setRulesModuleDao(RulesModuleDao rulesModuleDao)

getEventService

protected EventService getEventService()

setEventService

public void setEventService(EventService eventService)

getConcurrentMapFactory

protected ConcurrentMapFactory getConcurrentMapFactory()

setConcurrentMapFactory

public void setConcurrentMapFactory(ConcurrentMapFactory concurrentMapFactory)

getSuspendResumeTaskManager

public SuspendResumeTaskManager getSuspendResumeTaskManager()

Description copied from interface: RuleCompilationContext

get the suspend/resume task manager

Specified by:

getSuspendResumeTaskManager in interface RuleCompilationContext

Returns:

instance of SuspendResumeTaskManager

setSuspendResumeTaskManager

public void setSuspendResumeTaskManager(SuspendResumeTaskManager suspendResumeTaskManager)