Migrated to springboot 2.6.2

[nonrtric.git] / information-coordinator-service / src / main / java / org / oransc / ics / repository / InfoProducers.java

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 9d98eaa..19b2698 100644 (file)
--- 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();
     }