Class DefaultTasksQueueGateway
java.lang.Object
de.hybris.platform.task.impl.gateways.DefaultBaseGateway
de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
- All Implemented Interfaces:
BaseGateway,TasksQueueGateway
- Direct Known Subclasses:
HanaTasksQueueGateway,HsqldbTasksQueueGateway,MsSqlTasksQueueGateway,MySqlTasksQueueGateway,OracleTasksQueueGateway,PostgresTasksQueueGateway
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from interface de.hybris.platform.task.impl.gateways.TasksQueueGateway
TasksQueueGateway.TasksCountResult -
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final JDBCValueMappings.ValueWriter<Date,?> static final Stringprotected final JDBCValueMappings.ValueWriter<Integer,?> protected final JDBCValueMappings.ValueWriter<Long,?> static final Stringprotected static final Stringprotected static final StringFields inherited from class de.hybris.platform.task.impl.gateways.DefaultBaseGateway
jdbcTemplate -
Constructor Summary
ConstructorsConstructorDescriptionDefaultTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService) -
Method Summary
Modifier and TypeMethodDescriptionlongprotected longaddTasksInternal(String tasksQuery, String expiredTasksQuery, Instant now, int rangeStart, int rangeEnd) voidprotected voidcleanInternal(Duration taskProcessingTimeThreshold) booleandefaultIfNull(String columnName, Integer defaultValue) defaultIfNull(String columnName, String defaultValue) voiddeleteTasks(List<PK> tasks) protected StringgetCleanTasksQueueStatement(Duration taskProcessingTimeThreshold) getConditionsToSchedule(String conditionsQuery, Instant time) protected Stringprotected Stringprotected StringgetInsertTaskRowStatement(String subquery) protected StringgetLockTasksForProcessingStatement(Duration lockDuration) Deprecated, for removal: This API element is subject to removal in a future version.getLockTasksForProcessingStatementIfNeeded(Duration lockDuration) getRangeSQLExpression(int rangeStart, int rangeEnd) getSelectTasksWithExclusiveModeParams(long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Set<String> groups, Duration lockDuration) protected StringgetSelectTasksWithRangeParams(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Set<String> groups, Duration lockDuration) protected Stringprotected StringgetTableName(String code) getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Duration lockDuration) protected List<TasksProvider.VersionPK>getTasksForWorkerAndMarkForProcessingInternal(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Duration lockDuration) protected voidmarkTasksForProcessingInternal(String lockStatement, List<DefaultTasksQueueGateway.TasksQueueRow> tasksForWorker) voidunlockTasksForWorkers(List<Integer> invalidWorkerIds) Methods inherited from class de.hybris.platform.task.impl.gateways.DefaultBaseGateway
doesTableExist, dropTable, getJdbcTemplate, tryCreatingTableAndLogExceptionMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface de.hybris.platform.task.impl.gateways.BaseGateway
doesTableExist, dropTable
-
Field Details
-
SELECT_TASKS_WITH_RANGE
- See Also:
-
SELECT_TASKS_EXCLUSIVE_MODE
- See Also:
-
EMPTY_GROUP_VALUE
- See Also:
-
PROPERTY_RETRIES_IF_DEADLOCK_ON_GET_TASKS
- See Also:
-
intWriter
-
longWriter
-
dateWriter
-
-
Constructor Details
-
DefaultTasksQueueGateway
public DefaultTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService)
-
-
Method Details
-
getTableName
- Specified by:
getTableNamein interfaceBaseGateway
-
getTableName
-
getTasksForWorkerAndMarkForProcessing
public List<TasksProvider.VersionPK> getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Duration lockDuration) - Specified by:
getTasksForWorkerAndMarkForProcessingin interfaceTasksQueueGateway
-
getTasksForWorkerAndMarkForProcessingInternal
protected List<TasksProvider.VersionPK> getTasksForWorkerAndMarkForProcessingInternal(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Duration lockDuration) -
getSelectTasksWithRangeParams
protected Map<String,Object> getSelectTasksWithRangeParams(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Set<String> groups, Duration lockDuration) -
getSelectTasksWithExclusiveModeParams
-
getSelectTasksWithRangeQuery
-
getSelectTasksWithExclusiveModeQuery
-
clean
- Specified by:
cleanin interfaceTasksQueueGateway
-
cleanInternal
-
getCleanTasksQueueStatement
-
addTasks
public long addTasks(String tasksQuery, String expiredTasksQuery, Instant now, int rangeStart, int rangeEnd) - Specified by:
addTasksin interfaceTasksQueueGateway
-
addTasksInternal
-
getInsertTaskRowStatement
-
defaultIfNull
- Specified by:
defaultIfNullin interfaceTasksQueueGateway
-
defaultIfNull
- Specified by:
defaultIfNullin interfaceTasksQueueGateway
-
getEmptyGroupValue
- Specified by:
getEmptyGroupValuein interfaceTasksQueueGateway
-
getRangeSQLExpression
- Specified by:
getRangeSQLExpressionin interfaceTasksQueueGateway
-
getTasksCount
- Specified by:
getTasksCountin interfaceTasksQueueGateway
-
createTable
public boolean createTable()- Specified by:
createTablein interfaceBaseGateway- Overrides:
createTablein classDefaultBaseGateway
-
getCreateTableIndexStatements
-
getCreateTableStatement
- Specified by:
getCreateTableStatementin classDefaultBaseGateway
-
markTasksForProcessingInternal
protected void markTasksForProcessingInternal(String lockStatement, List<DefaultTasksQueueGateway.TasksQueueRow> tasksForWorker) -
getLockTasksForProcessingStatement
@Deprecated(since="20.05", forRemoval=true) protected String getLockTasksForProcessingStatement(Duration lockDuration) Deprecated, for removal: This API element is subject to removal in a future version.since 20.05, usegetLockTasksForProcessingStatementIfNeeded(Duration)instead -
getLockTasksForProcessingStatementIfNeeded
-
getUnlockTasksStatement
- Specified by:
getUnlockTasksStatementin interfaceTasksQueueGateway
-
deleteTasks
- Specified by:
deleteTasksin interfaceTasksQueueGateway
-
getDeleteTasksStatement
-
unlockTasksForWorkers
- Specified by:
unlockTasksForWorkersin interfaceTasksQueueGateway
-
getConditionsToSchedule
- Specified by:
getConditionsToSchedulein interfaceTasksQueueGateway
-
getLockTasksForProcessingStatementIfNeeded(Duration)instead