Class MsSqlTasksQueueGateway
java.lang.Object
de.hybris.platform.task.impl.gateways.DefaultBaseGateway
de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
de.hybris.platform.task.impl.gateways.MsSqlTasksQueueGateway
- 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
ConstructorsConstructorDescriptionMsSqlTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService) -
Method Summary
Modifier and TypeMethodDescriptionprotected StringgetCleanTasksQueueStatement(Duration taskProcessingTimeThreshold) protected Stringprotected Stringprotected StringgetInsertTaskRowStatement(String subquery) 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 StringMethods inherited from class de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
addTasks, addTasksInternal, clean, cleanInternal, createTable, defaultIfNull, defaultIfNull, deleteTasks, getConditionsToSchedule, getCreateTableIndexStatements, getEmptyGroupValue, getLockTasksForProcessingStatement, 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
-
MsSqlTasksQueueGateway
public MsSqlTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService)
-
-
Method Details
-
getCreateTableStatement
- Overrides:
getCreateTableStatementin classDefaultTasksQueueGateway
-
getCleanTasksQueueStatement
- Overrides:
getCleanTasksQueueStatementin classDefaultTasksQueueGateway
-
getInsertTaskRowStatement
- Overrides:
getInsertTaskRowStatementin classDefaultTasksQueueGateway
-
getSelectTasksWithRangeQuery
- Overrides:
getSelectTasksWithRangeQueryin classDefaultTasksQueueGateway
-
getSelectTasksWithExclusiveModeQuery
- Overrides:
getSelectTasksWithExclusiveModeQueryin classDefaultTasksQueueGateway
-
getLockTasksForProcessingStatementIfNeeded
- Overrides:
getLockTasksForProcessingStatementIfNeededin classDefaultTasksQueueGateway
-
getDeleteTasksStatement
- Overrides:
getDeleteTasksStatementin classDefaultTasksQueueGateway
-
getRangeSQLExpression
- Specified by:
getRangeSQLExpressionin interfaceTasksQueueGateway- Overrides:
getRangeSQLExpressionin classDefaultTasksQueueGateway
-
getSelectTasksWithRangeParams
protected Map<String,Object> getSelectTasksWithRangeParams(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Set<String> groups, Duration lockDuration) - Overrides:
getSelectTasksWithRangeParamsin classDefaultTasksQueueGateway
-
getSelectTasksWithExclusiveModeParams
protected Map<String,Object> getSelectTasksWithExclusiveModeParams(long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, Set<String> groups, Duration lockDuration) - Overrides:
getSelectTasksWithExclusiveModeParamsin classDefaultTasksQueueGateway
-