Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix formatting

Browse Source
This commit is contained in:
Mahmoud Ben Hassine
2022-08-10 11:38:58 +02:00
parent 9211c2d211
commit 14b443bc64
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-batch-integration/src/main/java/org/springframework/batch/integration/partition/MessageChannelPartitionHandler.java
View File

@@ -222,7 +222,8 @@ public class MessageChannelPartitionHandler extends AbstractPartitionHandler imp
* @see PartitionHandler#handle(StepExecutionSplitter, StepExecution)
*/
@Override
protected Set<StepExecution> doHandle(StepExecution managerStepExecution, Set<StepExecution> partitionStepExecutions) throws Exception {
protected Set<StepExecution> doHandle(StepExecution managerStepExecution,
Set<StepExecution> partitionStepExecutions) throws Exception {
if (CollectionUtils.isEmpty(partitionStepExecutions)) {
return partitionStepExecutions;
@@ -248,8 +249,8 @@ public class MessageChannelPartitionHandler extends AbstractPartitionHandler imp
}
}
private Set<StepExecution> pollReplies(final StepExecution managerStepExecution,
final Set<StepExecution> split) throws Exception {
private Set<StepExecution> pollReplies(final StepExecution managerStepExecution, final Set<StepExecution> split)
throws Exception {
final Set<StepExecution> result = new HashSet<>(split.size());
Callable<Set<StepExecution>> callback = new Callable<Set<StepExecution>>() {