Package de.hybris.platform.task.impl

Class TriggerTaskRunnerRetriesHandlingTest.TestTaskService

java.lang.Object

de.hybris.platform.task.impl.DefaultTaskService

de.hybris.platform.task.impl.TriggerTaskRunnerRetriesHandlingTest.TestTaskService

All Implemented Interfaces:

TaskService

Enclosing class:

TriggerTaskRunnerRetriesHandlingTest

public class TriggerTaskRunnerRetriesHandlingTest.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.Collection<java.lang.Long> relevantTasks)

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()
protected TaskRunner	getRunner(java.lang.String runnerBean)
protected TaskEngineParameters	getTaskProviderParameters()
void	setModelService(ModelService modelService)

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, 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

getRunner

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

Overrides:

getRunner in class DefaultTaskService

Throws:

java.lang.IllegalStateException

setModelService

public void setModelService(ModelService modelService)

Overrides:

setModelService in class DefaultTaskService

getExecutedTasks

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

getFailedTasks

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

getTaskProviderParameters

protected TaskEngineParameters getTaskProviderParameters()

Overrides:

getTaskProviderParameters in class DefaultTaskService