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
public class MsSqlTasksQueueGateway extends DefaultTasksQueueGateway
-
-
Nested Class Summary
-
Nested 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
-
Fields inherited from class de.hybris.platform.task.impl.gateways.DefaultBaseGateway
jdbcTemplate
-
-
Constructor Summary
Constructors Constructor Description MsSqlTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.StringgetCleanTasksQueueStatement(java.time.Duration taskProcessingTimeThreshold)protected java.lang.StringgetCreateTableStatement()protected java.lang.StringgetLockTasksForProcessingStatement(java.time.Duration lockDuration)protected java.lang.StringgetSelectTasksWithExclusiveModeQuery()protected java.lang.StringgetSelectTasksWithRangeQuery()-
Methods inherited from class de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
addTasks, clean, createTable, defaultIfNull, defaultIfNull, deleteTasks, getConditionsToSchedule, getCreateTableIndexStatements, getEmptyGroupValue, getInsertTaskRowStatement, getRangeSQLExpression, getTableName, getTableName, getTasksCount, getTasksForWorkerAndMarkForProcessing, getUnlockTasksStatement, unlockTasksForWorkers
-
Methods inherited from class de.hybris.platform.task.impl.gateways.DefaultBaseGateway
doesTableExist, dropTable, getJdbcTemplate, tryCreatingTableAndLogException
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface de.hybris.platform.task.impl.gateways.BaseGateway
doesTableExist, dropTable
-
-
-
-
Constructor Detail
-
MsSqlTasksQueueGateway
public MsSqlTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService)
-
-
Method Detail
-
getCreateTableStatement
protected java.lang.String getCreateTableStatement()
- Overrides:
getCreateTableStatementin classDefaultTasksQueueGateway
-
getCleanTasksQueueStatement
protected java.lang.String getCleanTasksQueueStatement(java.time.Duration taskProcessingTimeThreshold)
- Overrides:
getCleanTasksQueueStatementin classDefaultTasksQueueGateway
-
getSelectTasksWithRangeQuery
protected java.lang.String getSelectTasksWithRangeQuery()
- Overrides:
getSelectTasksWithRangeQueryin classDefaultTasksQueueGateway
-
getSelectTasksWithExclusiveModeQuery
protected java.lang.String getSelectTasksWithExclusiveModeQuery()
- Overrides:
getSelectTasksWithExclusiveModeQueryin classDefaultTasksQueueGateway
-
getLockTasksForProcessingStatement
protected java.lang.String getLockTasksForProcessingStatement(java.time.Duration lockDuration)
- Overrides:
getLockTasksForProcessingStatementin classDefaultTasksQueueGateway
-
-