de.hybris.platform.task.impl

Class AuxiliaryTablesWorkerRole

java.lang.Object

de.hybris.platform.task.impl.AuxiliaryTablesWorkerRole

public class AuxiliaryTablesWorkerRole
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AuxiliaryTablesWorkerRole.IntervalChecker

Constructor Summary

Constructors

Constructor and Description
AuxiliaryTablesWorkerRole()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	deleteTask(PK taskPk, boolean forceDbDelete, de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)
void	deleteTask(PK taskPk, de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)
void	deleteTasks(de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)
java.util.List<TasksProvider.VersionPK>	getTasksForWorker(WorkerStateGateway.WorkerRange workerRange, WorkerStateGateway.WorkerState workerState, long maxItemsToSchedule, de.hybris.platform.task.impl.RuntimeConfigHolder configHolder)
java.util.Optional<WorkerStateGateway.WorkerRange>	getWorkerRange(int nodeID)
WorkerStateGateway.WorkerState	registerAsWorker(TaskEngineParameters taskEngineParameters, de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)
void	setGatewayFactory(AuxiliaryTablesGatewayFactory gatewayFactory)
void	setMetricRegistry(MetricRegistry metricRegistry)
void	unregisterAsWorker(int nodeId)

Methods inherited from class java.lang.Object

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

Constructor Detail

AuxiliaryTablesWorkerRole

public AuxiliaryTablesWorkerRole()

Method Detail

registerAsWorker

public WorkerStateGateway.WorkerState registerAsWorker(TaskEngineParameters taskEngineParameters,
                                                       de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)

getWorkerRange

public java.util.Optional<WorkerStateGateway.WorkerRange> getWorkerRange(int nodeID)

getTasksForWorker

public java.util.List<TasksProvider.VersionPK> getTasksForWorker(WorkerStateGateway.WorkerRange workerRange,
                                                                 WorkerStateGateway.WorkerState workerState,
                                                                 long maxItemsToSchedule,
                                                                 de.hybris.platform.task.impl.RuntimeConfigHolder configHolder)

deleteTasks

public void deleteTasks(de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)

deleteTask

public void deleteTask(PK taskPk,
                       de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)

deleteTask

public void deleteTask(PK taskPk,
                       boolean forceDbDelete,
                       de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder)

unregisterAsWorker

public void unregisterAsWorker(int nodeId)

setGatewayFactory

public void setGatewayFactory(AuxiliaryTablesGatewayFactory gatewayFactory)

setMetricRegistry

public void setMetricRegistry(MetricRegistry metricRegistry)

afterPropertiesSet

public void afterPropertiesSet()