de.hybris.platform.task.impl.gateways

Interface TasksQueueGateway

All Superinterfaces:

BaseGateway

All Known Implementing Classes:

DefaultTasksQueueGateway, HanaTasksQueueGateway, MsSqlTasksQueueGateway, MySqlTasksQueueGateway, OracleTasksQueueGateway, PostgresTasksQueueGateway

public interface TasksQueueGateway
extends BaseGateway

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TasksQueueGateway.TasksCountResult

Method Summary

Modifier and Type	Method and Description
long	addTasks(java.lang.String tasksQuery, java.lang.String expiredTasksQuery, java.time.Instant now, int rangeStart, int rangeEnd)
void	clean(java.time.Duration taskProcessingTimeThreshold)
java.lang.String	defaultIfNull(java.lang.String columnName, java.lang.Integer defaultValue)
java.lang.String	defaultIfNull(java.lang.String columnName, java.lang.String defaultValue)
void	deleteTasks(java.util.List<PK> tasks)
java.util.List<TasksProvider.VersionPK>	getConditionsToSchedule(java.lang.String conditionsQuery, java.time.Instant time)
java.lang.String	getEmptyGroupValue()
java.lang.String	getRangeSQLExpression(int rangeStart, int rangeEnd)
java.util.List<TasksQueueGateway.TasksCountResult>	getTasksCount()
java.util.List<TasksProvider.VersionPK>	getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, java.time.Duration lockDuration)
java.lang.String	getUnlockTasksStatement()
void	unlockTasksForWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)

Methods inherited from interface de.hybris.platform.task.impl.gateways.BaseGateway

createTable, doesTableExist, dropTable, getTableName

Method Detail

getTasksForWorkerAndMarkForProcessing

java.util.List<TasksProvider.VersionPK> getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range,
                                                                              long maxItemsToSchedule,
                                                                              WorkerStateGateway.WorkerState workerState,
                                                                              java.time.Duration lockDuration)

clean

void clean(java.time.Duration taskProcessingTimeThreshold)

addTasks

long addTasks(java.lang.String tasksQuery,
              java.lang.String expiredTasksQuery,
              java.time.Instant now,
              int rangeStart,
              int rangeEnd)

defaultIfNull

java.lang.String defaultIfNull(java.lang.String columnName,
                               java.lang.Integer defaultValue)

defaultIfNull

java.lang.String defaultIfNull(java.lang.String columnName,
                               java.lang.String defaultValue)

getEmptyGroupValue

java.lang.String getEmptyGroupValue()

getRangeSQLExpression

java.lang.String getRangeSQLExpression(int rangeStart,
                                       int rangeEnd)

getTasksCount

java.util.List<TasksQueueGateway.TasksCountResult> getTasksCount()

getConditionsToSchedule

java.util.List<TasksProvider.VersionPK> getConditionsToSchedule(java.lang.String conditionsQuery,
                                                                java.time.Instant time)

getUnlockTasksStatement

java.lang.String getUnlockTasksStatement()

deleteTasks

void deleteTasks(java.util.List<PK> tasks)

unlockTasksForWorkers

void unlockTasksForWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)