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 -
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptiondefault voidafterTaskEngineStop(int nodeId, RuntimeConfigHolder runtimeConfigHolder) default voidafterTaskFinished(PK taskPk, RuntimeConfigHolder runtimeConfigHolder) default voidafterTaskUnlocked(PK taskPk, RuntimeConfigHolder runtimeConfigHolder) default voidbeforeTaskEngineStart(int nodeId) default intgetMaxItemsToSchedule(de.hybris.platform.task.impl.DefaultTaskService.TaskEngineRunningState runningState, RuntimeConfigHolder runtimeConfigHolder) getTasksToSchedule(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.default voidrefreshState(RuntimeConfigHolder runtimeConfigHolder, TaskEngineParameters taskEngineParameters) The method is responsible for refreshing state of the task provider.
-
Field Details
-
MAX_ITEMS_DEFAULT_MULTIPLIER
static final int MAX_ITEMS_DEFAULT_MULTIPLIER- See Also:
-
-
Method Details
-
getTasksToSchedule
List<TasksProvider.VersionPK> getTasksToSchedule(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 providertaskEngineParameters- parameters of task engine that should be taken intomaxItemsToSchedule- number of items that should (at maximum) be returned by tasks provider- Returns:
- collection of tasks' PKs
-
afterTaskFinished
-
afterTaskUnlocked
-
beforeTaskEngineStart
default void beforeTaskEngineStart(int nodeId) -
afterTaskEngineStop
-
getMaxItemsToSchedule
default int getMaxItemsToSchedule(de.hybris.platform.task.impl.DefaultTaskService.TaskEngineRunningState runningState, RuntimeConfigHolder runtimeConfigHolder) -
refreshState
default void refreshState(RuntimeConfigHolder runtimeConfigHolder, TaskEngineParameters taskEngineParameters) The method is responsible for refreshing state of the task provider.- Parameters:
runtimeConfigHolder- a simple services that holds the config properties used by tasks providertaskEngineParameters- parameters of task engine that should be taken into
-