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%2Fr1producer%2FProducerCallbacks.java;h=a97bdf66463497369bae4afd9cbced4f250ffd9b;hb=508e14c9ef1a74a87cf309262b0a2a1f057763e0;hp=61cd519d614e66e6dc2e25f691ae33d775cc6485;hpb=c675b454a3434d690695a7336700f78a51579400;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..a97bdf66 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 */ @@ -89,7 +89,7 @@ public class ProducerCallbacks { /** * 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));