Package de.hybris.platform.task.impl

Class AuxiliaryTablesBasedTaskProvider

java.lang.Object

de.hybris.platform.task.impl.AuxiliaryTablesBasedTaskProvider

All Implemented Interfaces:

TasksProvider

public class AuxiliaryTablesBasedTaskProvider
extends Object
implements TasksProvider

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.platform.task.impl.TasksProvider

TasksProvider.VersionPK

Field Summary

Fields

Modifier and Type	Field	Description
static final int	VERSION

Fields inherited from interface de.hybris.platform.task.impl.TasksProvider

MAX_ITEMS_DEFAULT_MULTIPLIER

Constructor Summary

Constructors

Constructor	Description
AuxiliaryTablesBasedTaskProvider()

Method Summary

Modifier and Type	Method	Description
void	afterTaskEngineStop(int nodeId, RuntimeConfigHolder runtimeConfigHolder)
void	afterTaskFinished(PK taskPk, RuntimeConfigHolder runtimeConfigHolder)
void	afterTaskUnlocked(PK taskPk, RuntimeConfigHolder runtimeConfigHolder)
int	getMaxItemsToSchedule(de.hybris.platform.task.impl.DefaultTaskService.TaskEngineRunningState runningState, RuntimeConfigHolder runtimeConfigHolder)
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.
void	setAuxiliaryTablesSchedulerRole(AuxiliaryTablesSchedulerRole auxiliaryTablesSchedulerRole)
void	setAuxiliaryTablesWorkerRole(AuxiliaryTablesWorkerRole auxiliaryTablesWorkerRole)

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.hybris.platform.task.impl.TasksProvider

beforeTaskEngineStart

Field Details

VERSION

public static final int VERSION

See Also:

• Constant Field Values

Constructor Details

AuxiliaryTablesBasedTaskProvider

public AuxiliaryTablesBasedTaskProvider()

Method Details

getTasksToSchedule

public List<TasksProvider.VersionPK> getTasksToSchedule(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

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

getMaxItemsToSchedule

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

Specified by:

getMaxItemsToSchedule in interface TasksProvider

afterTaskEngineStop

public void afterTaskEngineStop(int nodeId,
 RuntimeConfigHolder runtimeConfigHolder)

Specified by:

afterTaskEngineStop in interface TasksProvider

afterTaskFinished

public void afterTaskFinished(PK taskPk,
 RuntimeConfigHolder runtimeConfigHolder)

Specified by:

afterTaskFinished in interface TasksProvider

afterTaskUnlocked

public void afterTaskUnlocked(PK taskPk,
 RuntimeConfigHolder runtimeConfigHolder)

Specified by:

afterTaskUnlocked in interface TasksProvider

setAuxiliaryTablesWorkerRole

public void setAuxiliaryTablesWorkerRole(AuxiliaryTablesWorkerRole auxiliaryTablesWorkerRole)

setAuxiliaryTablesSchedulerRole

public void setAuxiliaryTablesSchedulerRole(AuxiliaryTablesSchedulerRole auxiliaryTablesSchedulerRole)