Package de.hybris.platform.task.impl
Class DelegatingTasksProvider
java.lang.Object
de.hybris.platform.task.impl.DelegatingTasksProvider
- All Implemented Interfaces:
TasksProvider
- Direct Known Subclasses:
AdjustItemsToScheduleCountTasksProvider,BufferedAuxTablesTasksProvider,ConfigurableTasksProvider
-
Nested Class Summary
Nested classes/interfaces inherited from interface de.hybris.platform.task.impl.TasksProvider
TasksProvider.VersionPK -
Field Summary
Fields inherited from interface de.hybris.platform.task.impl.TasksProvider
MAX_ITEMS_DEFAULT_MULTIPLIER -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidafterTaskEngineStop(int nodeId, RuntimeConfigHolder runtimeConfigHolder) voidafterTaskFinished(PK taskPk, RuntimeConfigHolder runtimeConfigHolder) voidafterTaskUnlocked(PK taskPk, RuntimeConfigHolder runtimeConfigHolder) voidbeforeTaskEngineStart(int nodeId) intgetMaxItemsToSchedule(de.hybris.platform.task.impl.DefaultTaskService.TaskEngineRunningState runningState, RuntimeConfigHolder runtimeConfigHolder) protected TasksProvidergetTasksToSchedule(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.voidrefreshState(RuntimeConfigHolder runtimeConfigHolder, TaskEngineParameters taskEngineParameters) The method is responsible for refreshing state of the task provider.
-
Constructor Details
-
DelegatingTasksProvider
-
-
Method Details
-
getTasksToSchedule
public List<TasksProvider.VersionPK> getTasksToSchedule(RuntimeConfigHolder runtimeConfigHolder, TaskEngineParameters taskEngineParameters, int maxItemsToSchedule) Description copied from interface:TasksProviderThe method should return a collection of tasks' PKs, that should be scheduled in this node's task engine.- Specified by:
getTasksToSchedulein interfaceTasksProvider- 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
- Specified by:
afterTaskFinishedin interfaceTasksProvider
-
afterTaskUnlocked
- Specified by:
afterTaskUnlockedin interfaceTasksProvider
-
beforeTaskEngineStart
public void beforeTaskEngineStart(int nodeId) - Specified by:
beforeTaskEngineStartin interfaceTasksProvider
-
afterTaskEngineStop
- Specified by:
afterTaskEngineStopin interfaceTasksProvider
-
getMaxItemsToSchedule
public int getMaxItemsToSchedule(de.hybris.platform.task.impl.DefaultTaskService.TaskEngineRunningState runningState, RuntimeConfigHolder runtimeConfigHolder) - Specified by:
getMaxItemsToSchedulein interfaceTasksProvider
-
refreshState
public void refreshState(RuntimeConfigHolder runtimeConfigHolder, TaskEngineParameters taskEngineParameters) Description copied from interface:TasksProviderThe method is responsible for refreshing state of the task provider.- Specified by:
refreshStatein interfaceTasksProvider- Parameters:
runtimeConfigHolder- a simple services that holds the config properties used by tasks providertaskEngineParameters- parameters of task engine that should be taken into
-
getTasksProvider
-