Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -81,9 +81,4 @@ public void beforeStep(StepExecution stepExecution) {
stepExecution.getJobExecution().getExecutionContext().remove("stepName");
}

@Override
public @Nullable ExitStatus afterStep(StepExecution stepExecution) {
return null;
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -132,11 +132,6 @@ private static Object deserialize(InputStream inputStream) {
}
}

@Override
public @Nullable ExitStatus afterStep(StepExecution stepExecution) {
return null;
}

@Override
public void beforeStep(StepExecution stepExecution) {
this.stepExecution = stepExecution;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,11 +96,6 @@ public void setValues(PreparedStatement ps, int i) throws SQLException {
});
}

@Override
public @Nullable ExitStatus afterStep(StepExecution stepExecution) {
return null;
}

@Override
public void beforeStep(StepExecution stepExecution) {
this.stepExecution = stepExecution;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@
@Import(DataSourceConfiguration.class)
public class PartitionJdbcJobConfiguration {

record Owner(int id, String firstName, String lastName) {
public record Owner(int id, String firstName, String lastName) {
}

@Bean
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,11 +58,10 @@ public DirectChannel requests() {
}

@Bean
public IntegrationFlow outboundFlow(ActiveMQConnectionFactory connectionFactory, BeanFactory beanFactory) {
StandardIntegrationFlow integrationFlow = IntegrationFlow.from(requests())
public IntegrationFlow outboundFlow(ActiveMQConnectionFactory connectionFactory) {
return IntegrationFlow.from(requests())
.handle(Jms.outboundAdapter(connectionFactory).destination("requests"))
.get();
return integrationFlow;
}

@Bean
Expand Down