Package de.hybris.platform.task.impl.gateways

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

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

Modifier and Type	Method	Description
protected String	getCleanTasksQueueStatement(Duration taskProcessingTimeThreshold)
protected String	getCreateTableStatement()
protected Optional<String>	getLockTasksForProcessingStatementIfNeeded(Duration lockDuration)
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, getDeleteTasksStatement, getEmptyGroupValue, getInsertTaskRowStatement, getLockTasksForProcessingStatement, getSelectTasksWithExclusiveModeParams, getSelectTasksWithExclusiveModeQuery, getSelectTasksWithRangeParams, 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 Details

PostgresTasksQueueGateway

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

Method Details

getCreateTableStatement

protected String getCreateTableStatement()

Overrides:

getCreateTableStatement in class DefaultTasksQueueGateway

getCleanTasksQueueStatement

protected String getCleanTasksQueueStatement(Duration taskProcessingTimeThreshold)

Overrides:

getCleanTasksQueueStatement in class DefaultTasksQueueGateway

getRangeSQLExpression

public String getRangeSQLExpression(int rangeStart,
 int rangeEnd)

Specified by:

getRangeSQLExpression in interface TasksQueueGateway

Overrides:

getRangeSQLExpression in class DefaultTasksQueueGateway

getLockTasksForProcessingStatementIfNeeded

protected Optional<String> getLockTasksForProcessingStatementIfNeeded(Duration lockDuration)

Overrides:

getLockTasksForProcessingStatementIfNeeded in class DefaultTasksQueueGateway