de.hybris.platform.task.impl.gateways

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

public class OracleTasksQueueGateway
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 and Description
OracleTasksQueueGateway(JdbcTemplate jdbcTemplate, TypeService typeService)

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	getCleanTasksQueueStatement(java.time.Duration taskProcessingTimeThreshold)
protected java.lang.String	getCreateTableStatement()
protected java.lang.String	getInsertTaskRowStatement(java.lang.String subquery)
protected java.lang.String	getLockTasksForProcessingStatement(java.time.Duration lockDuration)
java.lang.String	getRangeSQLExpression(int rangeStart, int rangeEnd)
protected java.lang.String	getSelectTasksWithExclusiveModeQuery()
protected java.lang.String	getSelectTasksWithRangeQuery()

Methods inherited from class de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway

addTasks, clean, createTable, defaultIfNull, defaultIfNull, deleteTasks, getConditionsToSchedule, getCreateTableIndexStatements, getEmptyGroupValue, 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

OracleTasksQueueGateway

public OracleTasksQueueGateway(JdbcTemplate jdbcTemplate,
                               TypeService typeService)

Method Detail

getCreateTableStatement

protected java.lang.String getCreateTableStatement()

Overrides:

getCreateTableStatement in class DefaultTasksQueueGateway

getSelectTasksWithRangeQuery

protected java.lang.String getSelectTasksWithRangeQuery()

Overrides:

getSelectTasksWithRangeQuery 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

getInsertTaskRowStatement

protected java.lang.String getInsertTaskRowStatement(java.lang.String subquery)

Overrides:

getInsertTaskRowStatement in class DefaultTasksQueueGateway

getSelectTasksWithExclusiveModeQuery

protected java.lang.String getSelectTasksWithExclusiveModeQuery()

Overrides:

getSelectTasksWithExclusiveModeQuery in class DefaultTasksQueueGateway

getLockTasksForProcessingStatement

protected java.lang.String getLockTasksForProcessingStatement(java.time.Duration lockDuration)

Overrides:

getLockTasksForProcessingStatement in class DefaultTasksQueueGateway