Simulating producer errors

[nonrtric.git] / enrichment-coordinator-service / src / main / java / org / oransc / enrichment / controllers / producer / ProducerController.java

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 c9b6467..7743bce 100644 (file)
--- 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);
         }