From f1c0456467faba762bfd4ecaca159bd914517a91 Mon Sep 17 00:00:00 2001 From: "Krzysztof Massalski (Extern)" Date: Fri, 8 Dec 2023 13:59:02 +0100 Subject: [PATCH] feat(impl):[#253] publish batch finish event only when its completed/error --- .../tractusx/irs/services/JobEventLinkedQueueListener.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/irs-api/src/main/java/org/eclipse/tractusx/irs/services/JobEventLinkedQueueListener.java b/irs-api/src/main/java/org/eclipse/tractusx/irs/services/JobEventLinkedQueueListener.java index a82582d36f..96da808214 100644 --- a/irs-api/src/main/java/org/eclipse/tractusx/irs/services/JobEventLinkedQueueListener.java +++ b/irs-api/src/main/java/org/eclipse/tractusx/irs/services/JobEventLinkedQueueListener.java @@ -85,7 +85,9 @@ private void checkIfIsCompleted(final UUID batchId, final LimitedJobEventQueue q log.info("BatchId: {} reached {} state.", batchId, batchProcessingState); saveUpdatedBatch(batch, progressList, batchProcessingState); queueMap.remove(batchId); - publishFinishProcessingEvent(batch, batchProcessingState); + if (isCompleted(batchProcessingState)) { + publishFinishProcessingEvent(batch, batchProcessingState); + } }); } }