diff --git a/hapi-fhir-storage-batch2/src/main/java/ca/uhn/fhir/batch2/coordinator/WorkChannelMessageHandler.java b/hapi-fhir-storage-batch2/src/main/java/ca/uhn/fhir/batch2/coordinator/WorkChannelMessageHandler.java index 2cb91328665..b6410888e20 100644 --- a/hapi-fhir-storage-batch2/src/main/java/ca/uhn/fhir/batch2/coordinator/WorkChannelMessageHandler.java +++ b/hapi-fhir-storage-batch2/src/main/java/ca/uhn/fhir/batch2/coordinator/WorkChannelMessageHandler.java @@ -253,16 +253,15 @@ class WorkChannelMessageHandler implements MessageHandler { .flatMap(MessageProcess::buildStepExecutor)); processingPreparation.ifPresentOrElse( - // all the setup is happy and committed. Do the work. - process -> process.myStepExector.executeStep(), - () -> { - // discard the chunk - ourLog.debug("Discarding chunk notification {}", workNotification); - }); + // all the setup is happy and committed. Do the work. + process -> process.myStepExector.executeStep(), + () -> { + // discard the chunk + ourLog.debug("Discarding chunk notification {}", workNotification); + }); } finally { BatchJobTracingContext.clearBatchJobsIds(); } - } /** @@ -305,5 +304,4 @@ class WorkChannelMessageHandler implements MessageHandler { MDC.remove(CHUNK_ID); } } - }