Interface TasksQueueGateway
- All Superinterfaces:
BaseGateway
- All Known Implementing Classes:
DefaultTasksQueueGateway,HanaTasksQueueGateway,HsqldbTasksQueueGateway,MsSqlTasksQueueGateway,MySqlTasksQueueGateway,OracleTasksQueueGateway,PostgresTasksQueueGateway
-
Nested Class Summary
Nested Classes -
Method Summary
Modifier and TypeMethodDescriptionlongvoiddefaultIfNull(String columnName, Integer defaultValue) defaultIfNull(String columnName, String defaultValue) voiddeleteTasks(List<PK> tasks) getConditionsToSchedule(String conditionsQuery, Instant time) getRangeSQLExpression(int rangeStart, int rangeEnd) getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Duration lockDuration) voidunlockTasksForWorkers(List<Integer> invalidWorkerIds) Methods inherited from interface de.hybris.platform.task.impl.gateways.BaseGateway
createTable, doesTableExist, dropTable, getTableName
-
Method Details
-
getTasksForWorkerAndMarkForProcessing
List<TasksProvider.VersionPK> getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Duration lockDuration) -
clean
-
addTasks
-
defaultIfNull
-
defaultIfNull
-
getEmptyGroupValue
String getEmptyGroupValue() -
getRangeSQLExpression
-
getTasksCount
List<TasksQueueGateway.TasksCountResult> getTasksCount() -
getConditionsToSchedule
-
getUnlockTasksStatement
String getUnlockTasksStatement() -
deleteTasks
-
unlockTasksForWorkers
-