From 14b443bc64c2008d15ea137d187f7c319fe9cfd6 Mon Sep 17 00:00:00 2001 From: Mahmoud Ben Hassine Date: Wed, 10 Aug 2022 11:38:58 +0200 Subject: [PATCH] Fix formatting --- .../partition/MessageChannelPartitionHandler.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/spring-batch-integration/src/main/java/org/springframework/batch/integration/partition/MessageChannelPartitionHandler.java b/spring-batch-integration/src/main/java/org/springframework/batch/integration/partition/MessageChannelPartitionHandler.java index 23a905388..4b48a6836 100644 --- a/spring-batch-integration/src/main/java/org/springframework/batch/integration/partition/MessageChannelPartitionHandler.java +++ b/spring-batch-integration/src/main/java/org/springframework/batch/integration/partition/MessageChannelPartitionHandler.java @@ -222,7 +222,8 @@ public class MessageChannelPartitionHandler extends AbstractPartitionHandler imp * @see PartitionHandler#handle(StepExecutionSplitter, StepExecution) */ @Override - protected Set doHandle(StepExecution managerStepExecution, Set partitionStepExecutions) throws Exception { + protected Set doHandle(StepExecution managerStepExecution, + Set partitionStepExecutions) throws Exception { if (CollectionUtils.isEmpty(partitionStepExecutions)) { return partitionStepExecutions; @@ -248,8 +249,8 @@ public class MessageChannelPartitionHandler extends AbstractPartitionHandler imp } } - private Set pollReplies(final StepExecution managerStepExecution, - final Set split) throws Exception { + private Set pollReplies(final StepExecution managerStepExecution, final Set split) + throws Exception { final Set result = new HashSet<>(split.size()); Callable> callback = new Callable>() {