PostgresTasksQueueGateway (hybris Commerce Suite 1905)

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

public class PostgresTasksQueueGateway
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

PostgresTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected java.lang.String`	`getCleanTasksQueueStatement(java.time.Duration taskProcessingTimeThreshold)`
`protected java.lang.String`	`getCreateTableStatement()`
`protected java.lang.String`	`getLockTasksForProcessingStatement(java.time.Duration lockDuration)`
`java.lang.String`	`getRangeSQLExpression(int rangeStart, int rangeEnd)`

Methods inherited from class de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway
addTasks, clean, createTable, defaultIfNull, defaultIfNull, deleteTasks, getConditionsToSchedule, getCreateTableIndexStatements, getEmptyGroupValue, getInsertTaskRowStatement, getSelectTasksWithExclusiveModeQuery, getSelectTasksWithRangeQuery, 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

PostgresTasksQueueGateway

public PostgresTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
                                 TypeService typeService)

Method Detail
- getCreateTableStatement
```
protected java.lang.String getCreateTableStatement()
```
  Overrides:
  
  getCreateTableStatement in class DefaultTasksQueueGateway
- getCleanTasksQueueStatement
```
protected java.lang.String getCleanTasksQueueStatement(java.time.Duration taskProcessingTimeThreshold)
```
  Overrides:
  
  getCleanTasksQueueStatement in class DefaultTasksQueueGateway
- getRangeSQLExpression
```
public java.lang.String getRangeSQLExpression(int rangeStart,
                                              int rangeEnd)
```
  Specified by:
  
  getRangeSQLExpression in interface TasksQueueGateway
  
  Overrides:
  
  getRangeSQLExpression in class DefaultTasksQueueGateway
- getLockTasksForProcessingStatement
```
protected java.lang.String getLockTasksForProcessingStatement(java.time.Duration lockDuration)
```
  Overrides:
  
  getLockTasksForProcessingStatement in class DefaultTasksQueueGateway