Package de.hybris.platform.task.impl

Class AdjustItemsToScheduleCountTasksProvider

java.lang.Object

de.hybris.platform.task.impl.DelegatingTasksProvider

de.hybris.platform.task.impl.AdjustItemsToScheduleCountTasksProvider

All Implemented Interfaces:

TasksProvider

public class AdjustItemsToScheduleCountTasksProvider
extends DelegatingTasksProvider

This class adjusts the number of items that should be provided by a delegated tasks provider. The implementation is not modifying the value returned by the DelegatingTasksProvider.getMaxItemsToSchedule(DefaultTaskService.TaskEngineRunningState, RuntimeConfigHolder) - the items returned by calling getTasksToSchedule(RuntimeConfigHolder, TaskEngineParameters, int) should be buffered (with ex. BufferedTasksProvider or handled in some other way.

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

Constructor	Description
AdjustItemsToScheduleCountTasksProvider(TasksProvider delegate, de.hybris.platform.task.impl.RuntimeConfigHolder.IntTaskEngineProperty relativeMaxItemsToScheduleMultiplier)

Method Summary

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

Methods inherited from class de.hybris.platform.task.impl.DelegatingTasksProvider

afterTaskEngineStop, afterTaskFinished, afterTaskUnlocked, beforeTaskEngineStart, getMaxItemsToSchedule, getTasksProvider

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AdjustItemsToScheduleCountTasksProvider

public AdjustItemsToScheduleCountTasksProvider(TasksProvider delegate,
                                               de.hybris.platform.task.impl.RuntimeConfigHolder.IntTaskEngineProperty relativeMaxItemsToScheduleMultiplier)

Method Detail

getTasksToSchedule

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

Description copied from interface: TasksProvider

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

Specified by:

getTasksToSchedule in interface TasksProvider

Overrides:

getTasksToSchedule in class DelegatingTasksProvider

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