X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=information-coordinator-service%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fics%2Frepository%2FInfoProducers.java;h=19b26985f3d24c0252ffd3e626e602c332dcd84a;hb=9fe98aaeb6bd40cbb46eb8bb1e7f46ce3c8d3b02;hp=9d98eaad1bf80a00aa8c31c1bf1f0677864cf448;hpb=c9c6839d27aaad72ff7b3140992e0ade4b0f07bb;p=nonrtric.git

diff --git a/information-coordinator-service/src/main/java/org/oransc/ics/repository/InfoProducers.java b/information-coordinator-service/src/main/java/org/oransc/ics/repository/InfoProducers.java
index 9d98eaad..19b26985 100644
--- a/information-coordinator-service/src/main/java/org/oransc/ics/repository/InfoProducers.java
+++ b/information-coordinator-service/src/main/java/org/oransc/ics/repository/InfoProducers.java
@@ -91,9 +91,9 @@ public class InfoProducers {
 
         producerCallbacks.startInfoJobs(producer, this.infoJobs) //
             .collectList() //
-            .flatMapMany(list -> consumerCallbacks.notifyJobStatus(producer.getInfoTypes())) //
+            .flatMapMany(list -> consumerCallbacks.notifyJobStatus(producer.getInfoTypes(), this)) //
             .collectList() //
-            .flatMapMany(list -> consumerCallbacks.notifyJobStatus(previousTypes)) //
+            .flatMapMany(list -> consumerCallbacks.notifyJobStatus(previousTypes, this)) //
             .subscribe();
 
         return producer;
@@ -136,7 +136,7 @@ public class InfoProducers {
                 this.logger.error("Bug, no producer found");
             }
         }
-        this.consumerCallbacks.notifyJobStatus(producer.getInfoTypes()) //
+        this.consumerCallbacks.notifyJobStatus(producer.getInfoTypes(), this) //
             .subscribe();
     }