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

public class DefaultTaskServiceBaseTest.TestTaskService
extends DefaultTaskService

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

DEFAULT_POLLING_INTERVAL, DEFAULT_SHUTDOWN_WAIT, DEFAULT_WORKER_MAX, PROCESSING_HITS_METRIC, PROCESSING_MISSES_METRIC, PROCESSING_TIME_METRIC, QUEUE_SIZE_METRIC

Fields inherited from interface de.hybris.platform.task.TaskService

BEAN_ID

Constructor Summary

Constructors

Constructor	Description
TestTaskService(int nodeId, java.util.Collection<java.lang.String> nodeGroups, java.util.concurrent.CountDownLatch countDownLatch, java.util.concurrent.CountDownLatch deleteCountDownLatch, java.util.Collection<java.lang.Long> relevantTasks)
TestTaskService(int nodeId, java.util.Collection<java.lang.String> nodeGroups, java.util.concurrent.CountDownLatch countDownLatch, java.util.concurrent.CountDownLatch deleteCountDownLatch, java.util.Collection<java.lang.Long> relevantTasks, boolean processTriggerTask)
TestTaskService(int nodeId, java.util.Collection<java.lang.String> nodeGroups, java.util.function.Predicate<TaskModel> shouldProcess, java.util.concurrent.CountDownLatch countDownLatch, java.util.concurrent.CountDownLatch deleteCountDownLatch, boolean isExclusive)
TestTaskService(int nodeId, java.util.Collection<java.lang.String> nodeGroups, java.util.function.Predicate<TaskModel> shouldProcess, java.util.concurrent.CountDownLatch countDownLatch, java.util.concurrent.CountDownLatch deleteCountDownLatch, boolean isExclusive, boolean processTriggerTask)

Method Summary

Modifier and Type	Method	Description
java.util.Collection<java.lang.Long>	getExecutedTasks()
protected TaskExecutionStrategy	getExecutionStrategy(TaskRunner<? extends TaskModel> runner)
java.util.Collection<java.lang.Long>	getFailedTasks()
int	getMaxItemsToSchedule()
protected TaskRunner	getRunner(java.lang.String runnerBean)
de.hybris.platform.task.impl.DefaultTaskServiceBaseTest.SpyTasksProvider	getSpyTaskProvider()
protected TaskEngineParameters	getTaskProviderParameters()

Methods inherited from class de.hybris.platform.task.impl.DefaultTaskService

checkSystemOK, checkTask, checkTaskConditions, destroy, getEngine, getRunner, getTaskDao, getTenant, init, isAllowedToStart, isAllowedToStart, isEnabledInConfig, isRunning, markTaskFailed, poll, process, processCondition, processInTenant, processTask, readExcludedNodesFromConfig, readMaxWorkersFromConfig, readPollingIntervalFromConfig, readShutdownWaitFromConfig, readWorkersIdleFromConfig, refreshCurrentSessionWithRetry, repoll, scheduleRetry, scheduleRetryIfAllowed, scheduleTask, setEventService, setMetricRegistry, setModelService, setScheduleAndTriggerStrategy, setTaskDao, setTaskEngineRetryTemplate, setTaskExecutionStrategies, setTasksProvider, triggerEvent, triggerEvent, triggerEvent, triggerRepoll, triggerRepollAfterSchedule, waitAndRunExclusiveAction

Methods inherited from class java.lang.Object

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

Constructor Detail

TestTaskService

public TestTaskService(int nodeId,
                       java.util.Collection<java.lang.String> nodeGroups,
                       java.util.concurrent.CountDownLatch countDownLatch,
                       java.util.concurrent.CountDownLatch deleteCountDownLatch,
                       java.util.Collection<java.lang.Long> relevantTasks)

TestTaskService

public TestTaskService(int nodeId,
                       java.util.Collection<java.lang.String> nodeGroups,
                       java.util.concurrent.CountDownLatch countDownLatch,
                       java.util.concurrent.CountDownLatch deleteCountDownLatch,
                       java.util.Collection<java.lang.Long> relevantTasks,
                       boolean processTriggerTask)

TestTaskService

public TestTaskService(int nodeId,
                       java.util.Collection<java.lang.String> nodeGroups,
                       java.util.function.Predicate<TaskModel> shouldProcess,
                       java.util.concurrent.CountDownLatch countDownLatch,
                       java.util.concurrent.CountDownLatch deleteCountDownLatch,
                       boolean isExclusive)

TestTaskService

public TestTaskService(int nodeId,
                       java.util.Collection<java.lang.String> nodeGroups,
                       java.util.function.Predicate<TaskModel> shouldProcess,
                       java.util.concurrent.CountDownLatch countDownLatch,
                       java.util.concurrent.CountDownLatch deleteCountDownLatch,
                       boolean isExclusive,
                       boolean processTriggerTask)

Method Detail

getExecutionStrategy

protected TaskExecutionStrategy getExecutionStrategy(TaskRunner<? extends TaskModel> runner)

Overrides:

getExecutionStrategy in class DefaultTaskService

getTaskProviderParameters

protected TaskEngineParameters getTaskProviderParameters()

Overrides:

getTaskProviderParameters in class DefaultTaskService

getSpyTaskProvider

public de.hybris.platform.task.impl.DefaultTaskServiceBaseTest.SpyTasksProvider getSpyTaskProvider()

getExecutedTasks

public java.util.Collection<java.lang.Long> getExecutedTasks()

getFailedTasks

public java.util.Collection<java.lang.Long> getFailedTasks()

getRunner

protected TaskRunner getRunner(java.lang.String runnerBean)
                        throws java.lang.IllegalStateException

Overrides:

getRunner in class DefaultTaskService

Throws:

java.lang.IllegalStateException

getMaxItemsToSchedule

public int getMaxItemsToSchedule()