Class JdbcSchedulerExecutionStore

java.lang.Object

org.chenile.scheduler.store.JdbcSchedulerExecutionStore

All Implemented Interfaces:

SchedulerExecutionStore

public class JdbcSchedulerExecutionStore
extends Object
implements SchedulerExecutionStore

Field Summary

Fields

Modifier and Type	Field	Description
private final JdbcTemplate	jdbcTemplate

Constructor Summary

Constructors

Constructor	Description
JdbcSchedulerExecutionStore(JdbcTemplate jdbcTemplate)

Method Summary

Modifier and Type	Method	Description
Optional<ScheduledExecutionRecord>	findByExecutionId(String executionId)
private ScheduledExecutionRecord	map(ResultSet rs)
void	markFailure(String executionId, int attempt, String errorMessage)
void	markSuccess(String executionId, int attempt, String launcherMetadata)
void	markTimedOut(String executionId, int attempt, String errorMessage)
private Instant	toInstant(Timestamp timestamp)
boolean	tryStartExecution(ScheduledExecutionRequest request)
private void	update(String executionId, int attempt, SchedulerExecutionStatus status, String errorMessage, String launcherMetadata)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

jdbcTemplate

private final JdbcTemplate jdbcTemplate

Constructor Details

JdbcSchedulerExecutionStore

public JdbcSchedulerExecutionStore(JdbcTemplate jdbcTemplate)

Method Details

tryStartExecution

public boolean tryStartExecution(ScheduledExecutionRequest request)

Specified by:

tryStartExecution in interface SchedulerExecutionStore

markSuccess

public void markSuccess(String executionId,
 int attempt,
 String launcherMetadata)

Specified by:

markSuccess in interface SchedulerExecutionStore

markFailure

public void markFailure(String executionId,
 int attempt,
 String errorMessage)

Specified by:

markFailure in interface SchedulerExecutionStore

markTimedOut

public void markTimedOut(String executionId,
 int attempt,
 String errorMessage)

Specified by:

markTimedOut in interface SchedulerExecutionStore

findByExecutionId

public Optional<ScheduledExecutionRecord> findByExecutionId(String executionId)

Specified by:

findByExecutionId in interface SchedulerExecutionStore

update

private void update(String executionId,
 int attempt,
 SchedulerExecutionStatus status,
 String errorMessage,
 String launcherMetadata)

map

private ScheduledExecutionRecord map(ResultSet rs)
                              throws SQLException

Throws:

SQLException

toInstant

private Instant toInstant(Timestamp timestamp)