X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-adaptor-java%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fdmaapadapter%2Fcontrollers%2FProducerCallbacksController.java;h=07f5aa72b4fdda2d5117aa2c8e3ddbc99c54917b;hb=d0c7f9207203ce9a502fc15c09f9938eebfd44f7;hp=e4dca5b886d61447a0d86cbafc1fa52a7b5a968c;hpb=968b89731a192c2ee3f3393d00519879ad89ce56;p=nonrtric.git diff --git a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/controllers/ProducerCallbacksController.java b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/controllers/ProducerCallbacksController.java index e4dca5b8..07f5aa72 100644 --- a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/controllers/ProducerCallbacksController.java +++ b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/controllers/ProducerCallbacksController.java @@ -82,11 +82,9 @@ public class ProducerCallbacksController { @RequestBody String body) { try { ProducerJobInfo request = gson.fromJson(body, ProducerJobInfo.class); - - logger.info("Job started callback {}", request.id); - Job job = new Job(request.id, request.targetUri, types.getType(request.typeId), request.owner, + logger.debug("Job started callback {}", request.id); + this.jobs.addJob(request.id, request.targetUri, types.getType(request.typeId), request.owner, request.lastUpdated, toJobParameters(request.jobData)); - this.jobs.put(job); return new ResponseEntity<>(HttpStatus.OK); } catch (Exception e) { return ErrorResponse.create(e, HttpStatus.NOT_FOUND); @@ -123,7 +121,7 @@ public class ProducerCallbacksController { public ResponseEntity jobDeletedCallback( // @PathVariable("infoJobId") String infoJobId) { - logger.info("Job deleted callback {}", infoJobId); + logger.debug("Job deleted callback {}", infoJobId); this.jobs.remove(infoJobId); return new ResponseEntity<>(HttpStatus.OK); }