de.hybris.platform.task.impl

Class DefaultTaskServiceNodeGroupsIntegrationTest.TestTaskService

java.lang.Object

de.hybris.platform.task.impl.DefaultTaskService

de.hybris.platform.task.impl.DefaultTaskServiceNodeGroupsIntegrationTest.TestTaskService

All Implemented Interfaces:

TaskService

Enclosing class:

DefaultTaskServiceNodeGroupsIntegrationTest

public class DefaultTaskServiceNodeGroupsIntegrationTest.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 and Description
TestTaskService(int nodeId, java.util.Collection<java.lang.String> nodeGroups, java.util.Collection<java.lang.Long> relevantTasks)

Method Summary

Modifier and Type	Method and Description
java.util.Collection<java.lang.Long>	getExecutedTasks()
protected TaskExecutionStrategy	getExecutionStrategy(TaskRunner<? extends TaskModel> runner)
java.util.Collection<java.lang.Long>	getFailedTasks()
protected TaskRunner	getRunner(java.lang.String runnerBean)

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

checkSystemOK, checkTask, checkTaskConditions, destroy, getEngine, getRunner, getTaskDao, getTaskProviderParameters, 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.Collection<java.lang.Long> relevantTasks)

Method Detail

getExecutionStrategy

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

Overrides:

getExecutionStrategy in class DefaultTaskService

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