Package de.hybris.platform.task.impl

Interface TasksProvider

All Known Implementing Classes:

AdjustItemsToScheduleCountTasksProvider, AuxiliaryTablesBasedTaskProvider, AuxiliaryTablesBasedTaskProviderTest.TasksProviderTest, BufferedAuxTablesTasksProvider, ConfigurableTasksProvider, DefaultTasksProvider, DelegatingTasksProvider, InMemoryTasksProvider

public interface TasksProvider

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	TasksProvider.VersionPK

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_ITEMS_DEFAULT_MULTIPLIER

Method Summary

Modifier and Type	Method	Description
default void	afterTaskEngineStop(int nodeId, de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)
default void	afterTaskFinished(PK taskPk, de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)
default void	afterTaskUnlocked(PK taskPk, de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)
default void	beforeTaskEngineStart(int nodeId)
default int	getMaxItemsToSchedule(de.hybris.platform.task.impl.DefaultTaskService.TaskEngineRunningState runningState, de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)
java.util.List<TasksProvider.VersionPK>	getTasksToSchedule(de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder, TaskEngineParameters taskEngineParameters, int maxItemsToSchedule)	The method should return a collection of tasks' PKs, that should be scheduled in this node's task engine.

Field Detail

MAX_ITEMS_DEFAULT_MULTIPLIER

static final int MAX_ITEMS_DEFAULT_MULTIPLIER

See Also:

Constant Field Values

Method Detail

getTasksToSchedule

java.util.List<TasksProvider.VersionPK> getTasksToSchedule(de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder,
                                                           TaskEngineParameters taskEngineParameters,
                                                           int maxItemsToSchedule)

The method should return a collection of tasks' PKs, that should be scheduled in this node's task engine.

Parameters:

runtimeConfigHolder - a simple services that holds the config properties used by tasks provider

taskEngineParameters - parameters of task engine that should be taken into

maxItemsToSchedule - number of items that should (at maximum) be returned by tasks provider

Returns:

collection of tasks' PKs

afterTaskFinished

default void afterTaskFinished(PK taskPk,
                               de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)

afterTaskUnlocked

default void afterTaskUnlocked(PK taskPk,
                               de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)

beforeTaskEngineStart

default void beforeTaskEngineStart(int nodeId)

afterTaskEngineStop

default void afterTaskEngineStop(int nodeId,
                                 de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)

getMaxItemsToSchedule

default int getMaxItemsToSchedule(de.hybris.platform.task.impl.DefaultTaskService.TaskEngineRunningState runningState,
                                  de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)