Package de.hybris.platform.task.impl
Class DefaultTaskServiceBaseTest.TestTaskService
java.lang.Object
de.hybris.platform.task.impl.DefaultTaskService
de.hybris.platform.task.impl.DefaultTaskServiceBaseTest.TestTaskService
- All Implemented Interfaces:
TaskService
- Enclosing class:
- DefaultTaskServiceBaseTest
-
Nested Class Summary
Nested classes/interfaces inherited from class de.hybris.platform.task.impl.DefaultTaskService
DefaultTaskService.PoolingQueueSizeGauge -
Field Summary
Fields inherited from class de.hybris.platform.task.impl.DefaultTaskService
CONDITIONS_QUEUE_SIZE_METRIC, DEFAULT_POLLING_INTERVAL, DEFAULT_SHUTDOWN_WAIT, DEFAULT_WORKER_MAX, POOLING_QUEUE_SIZE_METRIC, PROCESSING_HITS_METRIC, PROCESSING_MISSES_METRIC, PROCESSING_TIME_METRIC, QUEUE_SIZE_METRIC, TASKS_QUEUE_SIZE_METRICFields inherited from interface de.hybris.platform.task.TaskService
BEAN_ID -
Constructor Summary
ConstructorsConstructorDescriptionTestTaskService(int nodeId, Collection<String> nodeGroups, boolean isExclusive, boolean processTriggerTask, de.hybris.platform.task.impl.DefaultTaskServiceBaseTest.TestExecutionStrategy testExecutionStrategy, TaskRunner taskRunner) TestTaskService(int nodeId, Collection<String> nodeGroups, CountDownLatch countDownLatch, CountDownLatch deleteCountDownLatch, Collection<Long> relevantTasks) TestTaskService(int nodeId, Collection<String> nodeGroups, CountDownLatch countDownLatch, CountDownLatch deleteCountDownLatch, Collection<Long> relevantTasks, boolean processTriggerTask) TestTaskService(int nodeId, Collection<String> nodeGroups, Predicate<TaskModel> shouldProcess, CountDownLatch countDownLatch, CountDownLatch deleteCountDownLatch, boolean isExclusive) TestTaskService(int nodeId, Collection<String> nodeGroups, Predicate<TaskModel> shouldProcess, CountDownLatch countDownLatch, CountDownLatch deleteCountDownLatch, boolean isExclusive, boolean processTriggerTask) -
Method Summary
Modifier and TypeMethodDescriptiongetExecutionStrategy(TaskRunner<? extends TaskModel> runner) intprotected TaskRunnerde.hybris.platform.task.impl.DefaultTaskServiceBaseTest.SpyTasksProviderprotected TaskEngineParametersMethods inherited from class de.hybris.platform.task.impl.DefaultTaskService
checkSystemOK, checkTask, checkTaskConditions, destroy, getEngine, getRunner, getStrandedTasksLogic, getTaskDao, getTaskExecutionStrategies, getTenant, init, isAllowedToStart, isAllowedToStart, isEnabledInConfig, isRunning, markTaskFailed, poll, process, processCondition, processInTenant, processTask, readExcludedNodesFromConfig, readMaxWorkersFromConfig, readPollingIntervalFromConfig, readShutdownWaitFromConfig, readWorkersIdleFromConfig, refreshCurrentSessionWithRetry, repoll, scheduleRetry, scheduleRetryIfAllowed, scheduleRetryIfAllowed, scheduleTask, setEventService, setMetricRegistry, setModelService, setScheduleAndTriggerStrategy, setStrandedTasksLogic, setTaskDao, setTaskEngineRetryTemplate, setTaskExecutionStrategies, setTasksProvider, triggerEvent, triggerEvent, triggerEvent, triggerRepoll, triggerRepollAfterSchedule, waitAndRunExclusiveAction
-
Constructor Details
-
TestTaskService
public TestTaskService(int nodeId, Collection<String> nodeGroups, CountDownLatch countDownLatch, CountDownLatch deleteCountDownLatch, Collection<Long> relevantTasks) -
TestTaskService
public TestTaskService(int nodeId, Collection<String> nodeGroups, CountDownLatch countDownLatch, CountDownLatch deleteCountDownLatch, Collection<Long> relevantTasks, boolean processTriggerTask) -
TestTaskService
public TestTaskService(int nodeId, Collection<String> nodeGroups, Predicate<TaskModel> shouldProcess, CountDownLatch countDownLatch, CountDownLatch deleteCountDownLatch, boolean isExclusive) -
TestTaskService
public TestTaskService(int nodeId, Collection<String> nodeGroups, Predicate<TaskModel> shouldProcess, CountDownLatch countDownLatch, CountDownLatch deleteCountDownLatch, boolean isExclusive, boolean processTriggerTask) -
TestTaskService
public TestTaskService(int nodeId, Collection<String> nodeGroups, boolean isExclusive, boolean processTriggerTask, de.hybris.platform.task.impl.DefaultTaskServiceBaseTest.TestExecutionStrategy testExecutionStrategy, TaskRunner taskRunner)
-
-
Method Details
-
getExecutionStrategy
- Overrides:
getExecutionStrategyin classDefaultTaskService- Returns:
- task execution strategy assigned to task runner
-
getTaskProviderParameters
- Overrides:
getTaskProviderParametersin classDefaultTaskService
-
getSpyTaskProvider
public de.hybris.platform.task.impl.DefaultTaskServiceBaseTest.SpyTasksProvider getSpyTaskProvider() -
getExecutedTasks
-
getFailedTasks
-
getRunner
- Overrides:
getRunnerin classDefaultTaskService- Throws:
IllegalStateException
-
getMaxItemsToSchedule
public int getMaxItemsToSchedule()
-