diff --git a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/AutodetectJdbcCustomization.java b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/AutodetectJdbcCustomization.java index cdbcfd6b..8cd05aef 100644 --- a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/AutodetectJdbcCustomization.java +++ b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/AutodetectJdbcCustomization.java @@ -90,7 +90,8 @@ public boolean supportsSingleStatementLockAndFetch() { } @Override - public List lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit) { + public List lockAndFetchSingleStatement( + JdbcTaskRepositoryContext ctx, Instant now, int limit) { return jdbcCustomization.lockAndFetchSingleStatement(ctx, now, limit); } diff --git a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/DefaultJdbcCustomization.java b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/DefaultJdbcCustomization.java index 6bf35ddf..1b64081f 100644 --- a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/DefaultJdbcCustomization.java +++ b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/DefaultJdbcCustomization.java @@ -60,7 +60,8 @@ public boolean supportsSingleStatementLockAndFetch() { } @Override - public List lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit) { + public List lockAndFetchSingleStatement( + JdbcTaskRepositoryContext ctx, Instant now, int limit) { throw new UnsupportedOperationException( "lockAndFetch not supported for " + this.getClass().getName()); } diff --git a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/JdbcCustomization.java b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/JdbcCustomization.java index 849ca688..36d0e192 100644 --- a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/JdbcCustomization.java +++ b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/JdbcCustomization.java @@ -38,7 +38,8 @@ public interface JdbcCustomization { boolean supportsSingleStatementLockAndFetch(); - List lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit); + List lockAndFetchSingleStatement( + JdbcTaskRepositoryContext ctx, Instant now, int limit); boolean supportsGenericLockAndFetch(); diff --git a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/PostgreSqlJdbcCustomization.java b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/PostgreSqlJdbcCustomization.java index ce451f6a..c4c01c03 100644 --- a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/PostgreSqlJdbcCustomization.java +++ b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/PostgreSqlJdbcCustomization.java @@ -67,7 +67,8 @@ public String createGenericSelectForUpdateQuery( } @Override - public List lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit) { + public List lockAndFetchSingleStatement( + JdbcTaskRepositoryContext ctx, Instant now, int limit) { final JdbcTaskRepository.UnresolvedFilter unresolvedFilter = new JdbcTaskRepository.UnresolvedFilter(ctx.taskResolver.getUnresolved());