Skip to content

Commit

Permalink
Spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
kagkarlsson committed Jul 16, 2023
1 parent 4a664a7 commit 56f68ce
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,8 @@ public boolean supportsSingleStatementLockAndFetch() {
}

@Override
public List<Execution> lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit) {
public List<Execution> lockAndFetchSingleStatement(
JdbcTaskRepositoryContext ctx, Instant now, int limit) {
return jdbcCustomization.lockAndFetchSingleStatement(ctx, now, limit);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,8 @@ public boolean supportsSingleStatementLockAndFetch() {
}

@Override
public List<Execution> lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit) {
public List<Execution> lockAndFetchSingleStatement(
JdbcTaskRepositoryContext ctx, Instant now, int limit) {
throw new UnsupportedOperationException(
"lockAndFetch not supported for " + this.getClass().getName());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,8 @@ public interface JdbcCustomization {

boolean supportsSingleStatementLockAndFetch();

List<Execution> lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit);
List<Execution> lockAndFetchSingleStatement(
JdbcTaskRepositoryContext ctx, Instant now, int limit);

boolean supportsGenericLockAndFetch();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,8 @@ public String createGenericSelectForUpdateQuery(
}

@Override
public List<Execution> lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit) {
public List<Execution> lockAndFetchSingleStatement(
JdbcTaskRepositoryContext ctx, Instant now, int limit) {
final JdbcTaskRepository.UnresolvedFilter unresolvedFilter =
new JdbcTaskRepository.UnresolvedFilter(ctx.taskResolver.getUnresolved());

Expand Down

0 comments on commit 56f68ce

Please sign in to comment.