Class DefaultTaskServiceBaseTest

All Implemented Interfaces:
JaloSessionHolder
Direct Known Subclasses:
DefaultTaskServiceNodeGroupsIntegrationTest, DefaultTaskServicePollTest, DefaultTaskServiceRepollTest, TriggerTaskRunnerIntegrationTest

public abstract class DefaultTaskServiceBaseTest extends ServicelayerBaseTest
  • Field Details

    • tasksCreated

      protected final Set<PK> tasksCreated
    • modelService

      protected ModelService modelService
    • flexibleSearchService

      protected FlexibleSearchService flexibleSearchService
    • taskService

      protected TaskService taskService
    • typeService

      protected TypeService typeService
    • metricRegistry

      protected com.codahale.metrics.MetricRegistry metricRegistry
    • taskEngineRetryTemplate

      protected org.springframework.retry.support.RetryTemplate taskEngineRetryTemplate
    • strandedTasksLogic

      protected StrandedTasksLogic strandedTasksLogic
  • Constructor Details

    • DefaultTaskServiceBaseTest

      public DefaultTaskServiceBaseTest()
  • Method Details

    • setUp

      public void setUp()
    • tearDown

      public void tearDown()
    • markTaskForRemovalAfterTest

      protected void markTaskForRemovalAfterTest(PK pk)
    • createTask

      protected Long createTask(String group, UnaryOperator<TaskModel> extend)
    • createExpiredTask

      protected Long createExpiredTask(String group, UnaryOperator<TaskModel> extend)
    • createTask

      protected Long createTask(int nodeId, UnaryOperator<TaskModel> extend)
    • createExpiredTask

      protected Long createExpiredTask(int nodeId, UnaryOperator<TaskModel> extend)
    • createTask

      protected Long createTask(int nodeId, String group, UnaryOperator<TaskModel> extend)
    • createTask

      protected Long createTask()
    • createTask

      protected Long createTask(String group)
    • createExpiredTask

      protected Long createExpiredTask(String group)
    • createTask

      protected Long createTask(int nodeId)
    • createExpiredTask

      protected Long createExpiredTask(int nodeId)
    • createTask

      protected Long createTask(int nodeId, String group)
    • getTasksProvider

      protected abstract TasksProvider getTasksProvider()
    • assureTaskEngineStopped

      protected void assureTaskEngineStopped() throws TimeoutException
      Throws:
      TimeoutException
    • enableExclusiveMode

      protected void enableExclusiveMode()
    • resetExclusiveMode

      protected void resetExclusiveMode()