de.hybris.platform.task.impl

Interface TasksProvider

All Known Implementing Classes:

AuxiliaryTablesBasedTaskProvider, DefaultTasksProvider, InMemoryTasksProvider

public interface TasksProvider

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TasksProvider.VersionPK

Method Summary

Modifier and Type	Method and 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)
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.

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)