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