X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=enrichment-coordinator-service%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fenrichment%2Fcontrollers%2Fr1producer%2FProducerCallbacks.java;h=558ae79909ee1b4ef99e38268c5ba9db88d99eda;hb=0f6367023720ecc7d7b4b38cbbc4282792172a89;hp=61cd519d614e66e6dc2e25f691ae33d775cc6485;hpb=8fd8e9fc86a24be49d61841e381423120a41296d;p=nonrtric.git

diff --git a/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/r1producer/ProducerCallbacks.java b/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/r1producer/ProducerCallbacks.java
index 61cd519d..558ae799 100644
--- a/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/r1producer/ProducerCallbacks.java
+++ b/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/r1producer/ProducerCallbacks.java
@@ -75,7 +75,7 @@ public class ProducerCallbacks {
 
     /**
      * Start a job in all producers that suports the job type
-     * 
+     *
      * @param infoJob an Information Job
      * @return the number of producers that returned OK
      */
@@ -84,12 +84,12 @@ public class ProducerCallbacks {
         return Flux.fromIterable(getProducersForJob(infoJob, infoProducers)) //
             .flatMap(infoProducer -> startInfoJob(infoProducer, infoJob, retrySpec)) //
             .collectList() //
-            .flatMap(okResponses -> Mono.just(Integer.valueOf(okResponses.size()))); //
+            .map(okResponses -> Integer.valueOf(okResponses.size())); //
     }
 
     /**
      * Start all jobs for one producer
-     * 
+     *
      * @param producer
      * @param infoJobs
      */
@@ -111,7 +111,8 @@ public class ProducerCallbacks {
             .doOnNext(resp -> logger.debug("Job subscription {} started OK {}", infoJob.getId(), producer.getId())) //
             .onErrorResume(throwable -> {
                 producer.setJobDisabled(infoJob);
-                logger.warn("Job subscription failed {}", producer.getId(), throwable.toString());
+                logger.warn("Job subscription failed id: {} url: {}, reason: {}", producer.getId(),
+                    producer.getJobCallbackUrl(), throwable.toString());
                 return Mono.empty();
             }) //
             .doOnNext(resp -> producer.setJobEnabled(infoJob));