| Package | Description |
|---|---|
| de.hybris.platform.task.impl | |
| de.hybris.platform.task.impl.gateways |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<TasksProvider.VersionPK> |
AuxiliaryTablesWorkerRole.getTasksForWorker(WorkerStateGateway.WorkerRange workerRange,
WorkerStateGateway.WorkerState workerState,
long maxItemsToSchedule,
de.hybris.platform.task.impl.RuntimeConfigHolder configHolder) |
java.util.List<TasksProvider.VersionPK> |
InMemoryTasksProvider.getTasksToSchedule(de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder,
TaskEngineParameters taskEngineParameters,
int maxItemsToSchedule) |
java.util.List<TasksProvider.VersionPK> |
DefaultTasksProvider.getTasksToSchedule(de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder,
TaskEngineParameters taskEngineParameters,
int maxItemsToSchedule) |
java.util.List<TasksProvider.VersionPK> |
TasksProvider.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.
|
java.util.List<TasksProvider.VersionPK> |
AuxiliaryTablesBasedTaskProvider.getTasksToSchedule(de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder,
TaskEngineParameters taskEngineParameters,
int maxItemsToSchedule) |
java.util.Collection<TasksProvider.VersionPK> |
AuxiliaryTablesSchedulerRole.tryToPerformSchedulerJob(de.hybris.platform.task.impl.RuntimeConfigHolder runtimeConfigHolder,
TaskEngineParameters taskEngineParameters,
int maxItemsToSchedule) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DefaultTaskService.process(TasksProvider.VersionPK versionPK) |
protected void |
DefaultTaskService.processInTenant(TasksProvider.VersionPK versionPK) |
protected void |
DefaultTaskService.processTask(Task task,
TasksProvider.VersionPK versionPK) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<TasksProvider.VersionPK> |
TasksQueueGateway.getConditionsToSchedule(java.lang.String conditionsQuery,
java.time.Instant time) |
java.util.List<TasksProvider.VersionPK> |
DefaultTasksQueueGateway.getConditionsToSchedule(java.lang.String conditionsQuery,
java.time.Instant time) |
java.util.List<TasksProvider.VersionPK> |
TasksQueueGateway.getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range,
long maxItemsToSchedule,
WorkerStateGateway.WorkerState workerState,
java.time.Duration lockDuration) |
java.util.List<TasksProvider.VersionPK> |
DefaultTasksQueueGateway.getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range,
long maxItemsToSchedule,
WorkerStateGateway.WorkerState workerState,
java.time.Duration lockDuration) |
Copyright © 2018 SAP SE. All Rights Reserved.