Package de.hybris.platform.task.impl
Class AuxiliaryTablesWorkerRole
java.lang.Object
de.hybris.platform.task.impl.AuxiliaryTablesWorkerRole
- All Implemented Interfaces:
org.springframework.beans.factory.InitializingBean
public class AuxiliaryTablesWorkerRole
extends Object
implements org.springframework.beans.factory.InitializingBean
-
Nested Class Summary
Nested Classes -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidvoiddeleteTask(PK taskPk, boolean forceDbDelete, RuntimeConfigHolder runtimeConfigHolder) voiddeleteTask(PK taskPk, RuntimeConfigHolder runtimeConfigHolder) voiddeleteTasks(RuntimeConfigHolder runtimeConfigHolder) getTasksForWorker(WorkerStateGateway.WorkerRange workerRange, WorkerStateGateway.WorkerState workerState, long maxItemsToSchedule, RuntimeConfigHolder configHolder) getWorkerRange(int nodeID) registerAsWorker(TaskEngineParameters taskEngineParameters, RuntimeConfigHolder runtimeConfigHolder) voidsetGatewayFactory(AuxiliaryTablesGatewayFactory gatewayFactory) voidsetMetricRegistry(com.codahale.metrics.MetricRegistry metricRegistry) voidunregisterAsWorker(int nodeId)
-
Constructor Details
-
AuxiliaryTablesWorkerRole
public AuxiliaryTablesWorkerRole()
-
-
Method Details
-
registerAsWorker
public WorkerStateGateway.WorkerState registerAsWorker(TaskEngineParameters taskEngineParameters, RuntimeConfigHolder runtimeConfigHolder) -
getWorkerRange
-
getTasksForWorker
public List<TasksProvider.VersionPK> getTasksForWorker(WorkerStateGateway.WorkerRange workerRange, WorkerStateGateway.WorkerState workerState, long maxItemsToSchedule, RuntimeConfigHolder configHolder) -
deleteTasks
-
deleteTask
-
deleteTask
-
unregisterAsWorker
public void unregisterAsWorker(int nodeId) -
setGatewayFactory
-
setMetricRegistry
public void setMetricRegistry(com.codahale.metrics.MetricRegistry metricRegistry) -
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceorg.springframework.beans.factory.InitializingBean
-