X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=enrichment-coordinator-service%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fenrichment%2Fcontrollers%2Fproducer%2FProducerController.java;h=7743bce79a2a775bc7e6d4524f8ef5c3dd142893;hb=6a1eb6e2a6538decc54f5348fcb1589f5b829e68;hp=c9b6467c531a6d53bfd63648fc59e4cb6d8bbd94;hpb=0f8b3b162b7ab08cdfc998979cfa9866634893a6;p=nonrtric.git

diff --git a/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/producer/ProducerController.java b/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/producer/ProducerController.java
index c9b6467c..7743bce7 100644
--- a/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/producer/ProducerController.java
+++ b/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/producer/ProducerController.java
@@ -278,7 +278,11 @@ public class ProducerController {
 
         for (EiType type : types) {
             for (EiJob job : this.eiJobs.getJobsForType(type)) {
-                this.producerCallbacks.notifyProducerJobStarted(producer, job);
+                this.producerCallbacks.notifyProducerJobStarted(producer, job) //
+                    .subscribe(//
+                        response -> logger.debug("Producer notified OK"), //
+                        throwable -> logger.warn("Producer rejected job {}", throwable.getMessage()) //
+                    );
             }
             type.addProducer(producer);
         }