Class DefaultTaskContext

java.lang.Object
de.hybris.platform.ruleengine.concurrency.impl.DefaultTaskContext
All Implemented Interfaces:
TaskContext

public class DefaultTaskContext extends Object implements TaskContext
Default implementation of the TaskContext interface
  • Constructor Details

    • DefaultTaskContext

      public DefaultTaskContext()
  • Method Details

    • 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 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 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(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)