Class PostgresTasksQueueGateway
java.lang.Object
de.hybris.platform.task.impl.gateways.DefaultBaseGateway
de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
de.hybris.platform.task.impl.gateways.PostgresTasksQueueGateway
- 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
Fields 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
ConstructorsConstructorDescriptionPostgresTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService) -
Method Summary
Modifier and TypeMethodDescriptionprotected StringgetCleanTasksQueueStatement(Duration taskProcessingTimeThreshold) protected StringgetLockTasksForProcessingStatementIfNeeded(Duration lockDuration) getRangeSQLExpression(int rangeStart, int rangeEnd) Methods inherited from class de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
addTasks, addTasksInternal, clean, cleanInternal, createTable, defaultIfNull, defaultIfNull, deleteTasks, getConditionsToSchedule, getCreateTableIndexStatements, getDeleteTasksStatement, getEmptyGroupValue, getInsertTaskRowStatement, getLockTasksForProcessingStatement, getSelectTasksWithExclusiveModeParams, getSelectTasksWithExclusiveModeQuery, getSelectTasksWithRangeParams, getSelectTasksWithRangeQuery, getTableName, getTableName, getTasksCount, getTasksForWorkerAndMarkForProcessing, getTasksForWorkerAndMarkForProcessingInternal, 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
-
Constructor Details
-
PostgresTasksQueueGateway
public PostgresTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService)
-
-
Method Details
-
getCreateTableStatement
- Overrides:
getCreateTableStatementin classDefaultTasksQueueGateway
-
getCleanTasksQueueStatement
- Overrides:
getCleanTasksQueueStatementin classDefaultTasksQueueGateway
-
getRangeSQLExpression
- Specified by:
getRangeSQLExpressionin interfaceTasksQueueGateway- Overrides:
getRangeSQLExpressionin classDefaultTasksQueueGateway
-
getLockTasksForProcessingStatementIfNeeded
- Overrides:
getLockTasksForProcessingStatementIfNeededin classDefaultTasksQueueGateway
-