This commit is contained in:
jdar 2024-09-06 11:55:17 -07:00
parent c91bee21e9
commit f2150dd947
1 changed files with 6 additions and 8 deletions

View File

@ -253,16 +253,15 @@ class WorkChannelMessageHandler implements MessageHandler {
.flatMap(MessageProcess::buildStepExecutor)); .flatMap(MessageProcess::buildStepExecutor));
processingPreparation.ifPresentOrElse( processingPreparation.ifPresentOrElse(
// all the setup is happy and committed. Do the work. // all the setup is happy and committed. Do the work.
process -> process.myStepExector.executeStep(), process -> process.myStepExector.executeStep(),
() -> { () -> {
// discard the chunk // discard the chunk
ourLog.debug("Discarding chunk notification {}", workNotification); ourLog.debug("Discarding chunk notification {}", workNotification);
}); });
} finally { } finally {
BatchJobTracingContext.clearBatchJobsIds(); BatchJobTracingContext.clearBatchJobsIds();
} }
} }
/** /**
@ -305,5 +304,4 @@ class WorkChannelMessageHandler implements MessageHandler {
MDC.remove(CHUNK_ID); MDC.remove(CHUNK_ID);
} }
} }
} }