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=a5b0c057710ba2a4f13e73c2d1279f5ae9ec813c;hp=690f47cd731ce3444ba33ca10bf94ead2304c557;hpb=98ce5dc75fc222dadaf26a8a148788b0367bf6ca;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();
     }