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

Class DefaultTasksQueueGateway

java.lang.Object

de.hybris.platform.task.impl.gateways.DefaultBaseGateway

de.hybris.platform.task.impl.gateways.DefaultTasksQueueGateway

All Implemented Interfaces:

BaseGateway, TasksQueueGateway

Direct Known Subclasses:

HanaTasksQueueGateway, MsSqlTasksQueueGateway, MySqlTasksQueueGateway, OracleTasksQueueGateway, PostgresTasksQueueGateway

public class DefaultTasksQueueGateway
extends DefaultBaseGateway
implements TasksQueueGateway

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.platform.task.impl.gateways.TasksQueueGateway

TasksQueueGateway.TasksCountResult

Field Summary

Fields

Modifier and Type	Field	Description
protected JDBCValueMappings.ValueWriter<java.util.Date,?>	dateWriter
static java.lang.String	EMPTY_GROUP_VALUE
protected JDBCValueMappings.ValueWriter<java.lang.Integer,?>	intWriter
protected JDBCValueMappings.ValueWriter<java.lang.Long,?>	longWriter

Fields inherited from class de.hybris.platform.task.impl.gateways.DefaultBaseGateway

jdbcTemplate

Constructor Summary

Constructors

Constructor	Description
DefaultTasksQueueGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, TypeService typeService)

Method Summary

Modifier and Type	Method	Description
long	addTasks(java.lang.String tasksQuery, java.lang.String expiredTasksQuery, java.time.Instant now, int rangeStart, int rangeEnd)
void	clean(java.time.Duration taskProcessingTimeThreshold)
boolean	createTable()
java.lang.String	defaultIfNull(java.lang.String columnName, java.lang.Integer defaultValue)
java.lang.String	defaultIfNull(java.lang.String columnName, java.lang.String defaultValue)
void	deleteTasks(java.util.List<PK> tasks)
protected java.lang.String	getCleanTasksQueueStatement(java.time.Duration taskProcessingTimeThreshold)
java.util.List<TasksProvider.VersionPK>	getConditionsToSchedule(java.lang.String conditionsQuery, java.time.Instant time)
protected java.util.List<java.lang.String>	getCreateTableIndexStatements()
protected java.lang.String	getCreateTableStatement()
java.lang.String	getEmptyGroupValue()
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()
java.lang.String	getTableName()
protected java.lang.String	getTableName(java.lang.String code)
java.util.List<TasksQueueGateway.TasksCountResult>	getTasksCount()
java.util.List<TasksProvider.VersionPK>	getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range, long maxItemsToSchedule, WorkerStateGateway.WorkerState workerState, java.time.Duration lockDuration)
java.lang.String	getUnlockTasksStatement()
void	unlockTasksForWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)

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

Field Detail

EMPTY_GROUP_VALUE

public static final java.lang.String EMPTY_GROUP_VALUE

See Also:

Constant Field Values

intWriter

protected final JDBCValueMappings.ValueWriter<java.lang.Integer,?> intWriter

longWriter

protected final JDBCValueMappings.ValueWriter<java.lang.Long,?> longWriter

dateWriter

protected final JDBCValueMappings.ValueWriter<java.util.Date,?> dateWriter

Constructor Detail

DefaultTasksQueueGateway

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

Method Detail

getTableName

public java.lang.String getTableName()

Specified by:

getTableName in interface BaseGateway

getTableName

protected java.lang.String getTableName(java.lang.String code)

getTasksForWorkerAndMarkForProcessing

public java.util.List<TasksProvider.VersionPK> getTasksForWorkerAndMarkForProcessing(WorkerStateGateway.WorkerRange range,
                                                                                     long maxItemsToSchedule,
                                                                                     WorkerStateGateway.WorkerState workerState,
                                                                                     java.time.Duration lockDuration)

Specified by:

getTasksForWorkerAndMarkForProcessing in interface TasksQueueGateway

getSelectTasksWithRangeQuery

protected java.lang.String getSelectTasksWithRangeQuery()

getSelectTasksWithExclusiveModeQuery

protected java.lang.String getSelectTasksWithExclusiveModeQuery()

clean

public void clean(java.time.Duration taskProcessingTimeThreshold)

Specified by:

clean in interface TasksQueueGateway

getCleanTasksQueueStatement

protected java.lang.String getCleanTasksQueueStatement(java.time.Duration taskProcessingTimeThreshold)

addTasks

public long addTasks(java.lang.String tasksQuery,
                     java.lang.String expiredTasksQuery,
                     java.time.Instant now,
                     int rangeStart,
                     int rangeEnd)

Specified by:

addTasks in interface TasksQueueGateway

getInsertTaskRowStatement

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

defaultIfNull

public java.lang.String defaultIfNull(java.lang.String columnName,
                                      java.lang.Integer defaultValue)

Specified by:

defaultIfNull in interface TasksQueueGateway

defaultIfNull

public java.lang.String defaultIfNull(java.lang.String columnName,
                                      java.lang.String defaultValue)

Specified by:

defaultIfNull in interface TasksQueueGateway

getEmptyGroupValue

public java.lang.String getEmptyGroupValue()

Specified by:

getEmptyGroupValue in interface TasksQueueGateway

getRangeSQLExpression

public java.lang.String getRangeSQLExpression(int rangeStart,
                                              int rangeEnd)

Specified by:

getRangeSQLExpression in interface TasksQueueGateway

getTasksCount

public java.util.List<TasksQueueGateway.TasksCountResult> getTasksCount()

Specified by:

getTasksCount in interface TasksQueueGateway

createTable

public boolean createTable()

Specified by:

createTable in interface BaseGateway

Overrides:

createTable in class DefaultBaseGateway

getCreateTableIndexStatements

protected java.util.List<java.lang.String> getCreateTableIndexStatements()

getCreateTableStatement

protected java.lang.String getCreateTableStatement()

Specified by:

getCreateTableStatement in class DefaultBaseGateway

getLockTasksForProcessingStatement

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

getUnlockTasksStatement

public java.lang.String getUnlockTasksStatement()

Specified by:

getUnlockTasksStatement in interface TasksQueueGateway

deleteTasks

public void deleteTasks(java.util.List<PK> tasks)

Specified by:

deleteTasks in interface TasksQueueGateway

unlockTasksForWorkers

public void unlockTasksForWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)

Specified by:

unlockTasksForWorkers in interface TasksQueueGateway

getConditionsToSchedule

public java.util.List<TasksProvider.VersionPK> getConditionsToSchedule(java.lang.String conditionsQuery,
                                                                       java.time.Instant time)

Specified by:

getConditionsToSchedule in interface TasksQueueGateway