Class HanaTasksQueueGateway
java.lang.Object
de.hybris.platform.task.impl.gateways.DefaultBaseGateway
de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
de.hybris.platform.task.impl.gateways.HanaTasksQueueGateway
- All Implemented Interfaces:
BaseGateway,TasksQueueGateway
-
Nested Class Summary
Nested classes/interfaces inherited from class de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
DefaultTasksQueueGateway.TasksQueueRowNested classes/interfaces inherited from interface de.hybris.platform.task.impl.gateways.TasksQueueGateway
TasksQueueGateway.TasksCountResult -
Field Summary
FieldsFields inherited from class de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
dateWriter, EMPTY_GROUP_VALUE, intWriter, longWriter, PROPERTY_RETRIES_IF_DEADLOCK_ON_GET_TASKS, SELECT_TASKS_EXCLUSIVE_MODE, SELECT_TASKS_WITH_RANGEFields inherited from class de.hybris.platform.task.impl.gateways.DefaultBaseGateway
jdbcTemplate -
Constructor Summary
ConstructorsConstructorDescriptionHanaTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService) Deprecated, for removal: This API element is subject to removal in a future version.HanaTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService, Supplier<Optional<AdditionalDatabaseData>> additionalDatabaseDataSupplier) -
Method Summary
Modifier and TypeMethodDescriptionprotected longaddTasksInternal(String tasksQuery, String expiredTasksQuery, Instant now, int rangeStart, int rangeEnd) protected voidcleanInternal(Duration taskProcessingTimeThreshold) protected StringgetCleanTasksQueueStatement(Duration taskProcessingTimeThreshold) protected StringgetLockTasksForProcessingStatementIfNeeded(Duration lockDuration) protected Stringprotected Stringprotected List<TasksProvider.VersionPK>getTasksForWorkerAndMarkForProcessingInternal(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Duration lockDuration) Methods inherited from class de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
addTasks, clean, createTable, defaultIfNull, defaultIfNull, deleteTasks, getConditionsToSchedule, getCreateTableIndexStatements, getDeleteTasksStatement, getEmptyGroupValue, getInsertTaskRowStatement, getLockTasksForProcessingStatement, getRangeSQLExpression, getSelectTasksWithExclusiveModeParams, getSelectTasksWithRangeParams, getTableName, getTableName, getTasksCount, getTasksForWorkerAndMarkForProcessing, getUnlockTasksStatement, markTasksForProcessingInternal, unlockTasksForWorkersMethods 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
-
PROPERTY_DISABLE_LOCK_ON_GET_TASKS
- See Also:
-
-
Constructor Details
-
HanaTasksQueueGateway
@Deprecated(since="2211", forRemoval=true) public HanaTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService) Deprecated, for removal: This API element is subject to removal in a future version.since 2211, useHanaTasksQueueGateway(JdbcTemplate, TypeService, Supplier) -
HanaTasksQueueGateway
public HanaTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService, Supplier<Optional<AdditionalDatabaseData>> additionalDatabaseDataSupplier)
-
-
Method Details
-
getCreateTableStatement
- Overrides:
getCreateTableStatementin classDefaultTasksQueueGateway
-
getCleanTasksQueueStatement
- Overrides:
getCleanTasksQueueStatementin classDefaultTasksQueueGateway
-
getSelectTasksWithRangeQuery
- Overrides:
getSelectTasksWithRangeQueryin classDefaultTasksQueueGateway
-
getSelectTasksWithExclusiveModeQuery
- Overrides:
getSelectTasksWithExclusiveModeQueryin classDefaultTasksQueueGateway
-
cleanInternal
- Overrides:
cleanInternalin classDefaultTasksQueueGateway
-
addTasksInternal
protected long addTasksInternal(String tasksQuery, String expiredTasksQuery, Instant now, int rangeStart, int rangeEnd) - Overrides:
addTasksInternalin classDefaultTasksQueueGateway
-
getTasksForWorkerAndMarkForProcessingInternal
protected List<TasksProvider.VersionPK> getTasksForWorkerAndMarkForProcessingInternal(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Duration lockDuration) - Overrides:
getTasksForWorkerAndMarkForProcessingInternalin classDefaultTasksQueueGateway
-
getLockTasksForProcessingStatementIfNeeded
- Overrides:
getLockTasksForProcessingStatementIfNeededin classDefaultTasksQueueGateway
-
HanaTasksQueueGateway(JdbcTemplate, TypeService, Supplier)