de.hybris.platform.ruleengine.concurrency.impl

Class DefaultTaskContext

java.lang.Object

de.hybris.platform.ruleengine.concurrency.impl.DefaultTaskContext

All Implemented Interfaces:

TaskContext

public class DefaultTaskContext
extends java.lang.Object
implements TaskContext

Default implementation of the TaskContext interface

Constructor Summary

Constructors

Constructor and Description
DefaultTaskContext()

Method Summary

Modifier and Type	Method and Description
protected ConcurrentMapFactory	getConcurrentMapFactory()
protected ConfigurationService	getConfigurationService()
Tenant	getCurrentTenant() Get the currently active tenant
int	getNumberOfThreads() get the maximum number of threads to allocate for multi-thread execution
protected RuleEngineSpliteratorStrategy	getRuleEngineSpliteratorStrategy()
protected RulesModuleDao	getRulesModuleDao()
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	setConcurrentMapFactory(ConcurrentMapFactory concurrentMapFactory)
void	setConfigurationService(ConfigurationService configurationService)
void	setCurrentTenant(Tenant currentTenant)
void	setRuleEngineSpliteratorStrategy(RuleEngineSpliteratorStrategy ruleEngineSpliteratorStrategy)
void	setRulesModuleDao(RulesModuleDao rulesModuleDao)
void	setThreadFactory(java.util.concurrent.ThreadFactory threadFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTaskContext

public DefaultTaskContext()

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

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

setCurrentTenant

public void setCurrentTenant(Tenant currentTenant)

setThreadFactory

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

setConfigurationService

public void setConfigurationService(ConfigurationService configurationService)

getConfigurationService

protected ConfigurationService getConfigurationService()

getRulesModuleDao

protected RulesModuleDao getRulesModuleDao()

setRulesModuleDao

public void setRulesModuleDao(RulesModuleDao rulesModuleDao)

getConcurrentMapFactory

protected ConcurrentMapFactory getConcurrentMapFactory()

setConcurrentMapFactory

public void setConcurrentMapFactory(ConcurrentMapFactory concurrentMapFactory)

getRuleEngineSpliteratorStrategy

protected RuleEngineSpliteratorStrategy getRuleEngineSpliteratorStrategy()

setRuleEngineSpliteratorStrategy

public void setRuleEngineSpliteratorStrategy(RuleEngineSpliteratorStrategy ruleEngineSpliteratorStrategy)