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%2FProducerController.java;h=0aa6974e91c9ba9c9b49825be10eb44900128365;hb=8e5ec9ba0617881c1cd5f72c3cce2bdfca4461fb;hp=6c3c05dda2a8a98d84d52520906df7c0617470a7;hpb=f09d7ed9c458244bd8edbf38f689cff75bd19790;p=nonrtric.git diff --git a/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/r1producer/ProducerController.java b/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/r1producer/ProducerController.java index 6c3c05dd..0aa6974e 100644 --- a/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/r1producer/ProducerController.java +++ b/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/controllers/r1producer/ProducerController.java @@ -149,7 +149,8 @@ public class ProducerController { if (registrationInfo.jobDataSchema == null) { return ErrorResponse.create("No schema provided", HttpStatus.BAD_REQUEST); } - InfoType newDefinition = new InfoType(infoTypeId, registrationInfo.jobDataSchema); + InfoType newDefinition = + new InfoType(infoTypeId, registrationInfo.jobDataSchema, registrationInfo.typeSpecificInformation); this.infoTypes.put(newDefinition); this.typeSubscriptions.notifyTypeRegistered(newDefinition); return new ResponseEntity<>(previousDefinition == null ? HttpStatus.CREATED : HttpStatus.OK); @@ -394,7 +395,7 @@ public class ProducerController { } private ProducerInfoTypeInfo toInfoTypeInfo(InfoType t) { - return new ProducerInfoTypeInfo(t.getJobDataSchema()); + return new ProducerInfoTypeInfo(t.getJobDataSchema(), t.getTypeSpecificInfo()); } private InfoProducers.InfoProducerRegistrationInfo toProducerRegistrationInfo(String infoProducerId,