X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=information-coordinator-service%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fics%2Ftasks%2FProducerSupervision.java;h=36ca28e07edf0efaa04ef06ac6ff1f7db61f4ddc;hb=21c2d3065fdf0d8b8c8680d292b524248622875f;hp=690f47cd731ce3444ba33ca10bf94ead2304c557;hpb=09e21f39a3ffcfc2063110bcad028014b0056398;p=nonrtric.git

diff --git a/information-coordinator-service/src/main/java/org/oransc/ics/tasks/ProducerSupervision.java b/information-coordinator-service/src/main/java/org/oransc/ics/tasks/ProducerSupervision.java
index 690f47cd..36ca28e0 100644
--- a/information-coordinator-service/src/main/java/org/oransc/ics/tasks/ProducerSupervision.java
+++ b/information-coordinator-service/src/main/java/org/oransc/ics/tasks/ProducerSupervision.java
@@ -89,7 +89,7 @@ public class ProducerSupervision {
             .filter(infoJob -> !producer.isJobEnabled(infoJob)) //
             .flatMap(infoJob -> producerCallbacks.startInfoJob(producer, infoJob, Retry.max(1)), MAX_CONCURRENCY) //
             .collectList() //
-            .flatMapMany(startedJobs -> consumerCallbacks.notifyJobStatus(producer.getInfoTypes())) //
+            .flatMapMany(startedJobs -> consumerCallbacks.notifyJobStatus(producer.getInfoTypes(), infoProducers)) //
             .collectList();
     }