Merge pull request #692 from catenax-ng/feature/#253-fix-bug

feat(impl):[#253] publish batch finish event only when its completed/…
eclipse-tractusx · Dec 8, 2023 · c0bb503 · c0bb503
2 parents c8944d9 + f1c0456
commit c0bb503
Showing 1 changed file with 3 additions and 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
@@ -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);
+                }
             });
         }
     }