feat(impl):[#253] publish batch finish event only when its completed/…

…error
eclipse-tractusx · Dec 8, 2023 · f1c0456 · f1c0456
1 parent 2c751f1
commit f1c0456
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);
+                }
             });
         }
     }