Create RAN App in RAN-Sim to support A1-based action for SON Use Case

Issue-ID: INT-2129
Signed-off-by: vvarvate <vv00489503@techmahindra.com>
Change-Id: Iba1bd825a612ea93ea5611dda818330bb399642c

21 files changed, 1138 insertions, 0 deletions

diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/client/KafkaClientRanappTopic.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/client/KafkaClientRanappTopic.java
new file mode 100644
index 0000000..e80b8e1
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/client/KafkaClientRanappTopic.java
@@ -0,0 +1,100 @@
+package org.onap.ranapp.kafka.client;
+import java.util.Arrays;
+import java.util.Properties;
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.apache.kafka.clients.consumer.KafkaConsumer;
+import org.apache.kafka.common.serialization.StringDeserializer;
+import org.onap.ranapp.kafka.listener.RanAppEventConsumer;
+import org.onap.ranapp.kafka.model.appmodels.PolicytypetoTopicMapping;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.http.ResponseEntity;
+import org.springframework.retry.backoff.FixedBackOffPolicy;
+import org.springframework.retry.policy.SimpleRetryPolicy;
+import org.springframework.retry.support.RetryTemplate;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+import lombok.AccessLevel;
+import lombok.Getter;
+import reactor.core.Disposable;
+@Component
+public class KafkaClientRanappTopic {
+
+ private static final Logger logger = LoggerFactory.getLogger(KafkaClientRanappTopic.class);
+
+ @Value("${kafkadispatcher.url}")
+ private String kafkaclient_url;
+ @Value("${ranapp.policytype}")
+ private String policytype_name;
+
+ @Value(value = "${kafka.bootstrapAddress}")
+ private String bootstrapAddress;
+ @Value(value = "${ranapp.testing.topic.id}")
+ private String groupId;
+
+ public static String requestTopicName = "";
+
+ public static String responseTopicName = "";
+
+ @Getter(AccessLevel.PROTECTED)
+ private Disposable refreshTask = null;
+
+ @Autowired
+ RanAppEventConsumer ranappeventconsumer;
+
+ private RestTemplate restTemplate = new RestTemplate();
+
+ @Bean
+   public RetryTemplate retryTemplate() {
+     int maxAttempt = Integer.parseInt("10");
+     int retryTimeInterval = Integer.parseInt("5000");
+     SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
+     retryPolicy.setMaxAttempts(maxAttempt);
+     FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
+     backOffPolicy.setBackOffPeriod(retryTimeInterval); // 1.5 seconds
+     RetryTemplate template = new RetryTemplate();
+     template.setRetryPolicy(retryPolicy);
+     template.setBackOffPolicy(backOffPolicy);
+     return template;
+   }
+
+ public void getRanApp_KafkaTopicnames() {
+  logger.info("Requesting for KafkaTopics");
+  stop();
+  refreshTask=retryTemplate().execute(context -> {
+   String url = kafkaclient_url + policytype_name ;
+         System.out.println("retrying Connection:   "+url);
+
+
+         ResponseEntity<PolicytypetoTopicMapping> requestData = restTemplate.getForEntity(url, PolicytypetoTopicMapping.class);
+         PolicytypetoTopicMapping policytoTopicMapping=requestData.getBody();
+         requestTopicName=policytoTopicMapping.getRequest_topic();
+         responseTopicName=policytoTopicMapping.getResponse_topic();
+         logger.info("Request Topic for Policy "+ policytype_name +" "+ requestTopicName);
+         logger.info("Response Topic for Policy "+ policytype_name +" "+ responseTopicName);
+
+         Properties properties=new Properties();
+         properties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,bootstrapAddress);
+         properties.setProperty(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,   StringDeserializer.class.getName());
+         properties.setProperty(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,StringDeserializer.class.getName());
+         properties.setProperty(ConsumerConfig.GROUP_ID_CONFIG,groupId);
+         properties.setProperty(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,"earliest");
+         //creating consumer
+         KafkaConsumer<String,String> consumer= new KafkaConsumer<String,String>(properties);
+         //Subscribing
+                 consumer.subscribe(Arrays.asList(requestTopicName));
+                 ranappeventconsumer.consume(consumer,requestTopicName,responseTopicName);
+       logger.info("Response ..."+ requestData);
+             throw new IllegalStateException("Something went wrong");
+         });
+ }
+
+ public void stop() {
+        if (refreshTask != null) {
+            refreshTask.dispose();
+        }
+    }
+}
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/listener/RanAppEventConsumer.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/listener/RanAppEventConsumer.java
new file mode 100644
index 0000000..037dd54
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/listener/RanAppEventConsumer.java
@@ -0,0 +1,169 @@
+package org.onap.ranapp.kafka.listener;
+import java.time.Duration;
+import java.util.LinkedList;
+import java.util.List;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.KafkaConsumer;
+import org.json.JSONObject;
+import org.onap.ranapp.kafka.model.appmodels.ANRInputMessage;
+import org.onap.ranapp.kafka.model.appmodels.ANROutputMessage;
+import org.onap.ranapp.kafka.model.appmodels.CellConfig;
+import org.onap.ranapp.kafka.model.appmodels.Common;
+import org.onap.ranapp.kafka.model.appmodels.Configuration;
+import org.onap.ranapp.kafka.model.appmodels.Data;
+import org.onap.ranapp.kafka.model.appmodels.FAPService;
+import org.onap.ranapp.kafka.model.appmodels.LTE;
+import org.onap.ranapp.kafka.model.appmodels.LTECell;
+import org.onap.ranapp.kafka.model.appmodels.NeighborListInUse;
+import org.onap.ranapp.kafka.model.appmodels.PayloadOutput;
+import org.onap.ranapp.kafka.model.appmodels.RAN;
+import org.onap.ranapp.kafka.model.appmodels.ResponsetoA1;
+import org.onap.ranapp.models.DeviceData;
+import org.onap.ranapp.models.MessageType;
+import org.onap.ranapp.websocket.WebsocketClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.stereotype.Service;
+import com.fasterxml.jackson.databind.ObjectMapper;
+@Service
+public class RanAppEventConsumer {
+ private final Logger  logger = LoggerFactory.getLogger(RanAppEventConsumer.class);
+ public RanAppEventConsumer() {
+ }
+
+
+ @Value("${ranapp.hokpi1_threshold}")
+ private int hokpiThreshold;
+
+ @Value(value = "${kafka.bootstrapAddress}")
+ private String bootstrapAddress;
+ ObjectMapper objectMapper = new ObjectMapper();
+
+ @Autowired
+ KafkaTemplate<String, Object> Kafkatemplate;
+
+ @Autowired
+ WebsocketClient websocketclient;
+
+ ResponsetoA1 response=new ResponsetoA1();
+
+ public static String requestTopicName,responseTopicName;
+
+ //@KafkaListener(topics = "#{topicUtil.suffixTopics()}", groupId = "${ranapp.testing.topic.id}", containerFactory = "kafkaListenerFactory")
+ public void consume(KafkaConsumer<String,String> consumer, String requesttopicName, String responsetopicName) {
+  try {
+   requestTopicName=requesttopicName;
+   responseTopicName=responsetopicName;
+   WebsocketClient.requestTopicName=requesttopicName;
+   WebsocketClient.responseTopicName=responsetopicName;
+
+  while(true){
+            ConsumerRecords<String,String> records=consumer.poll(Duration.ofMillis(1000));
+            for(ConsumerRecord<String,String> record: records){
+                logger.info("Key: "+ record.key() + ", Value:" +record.value());
+                logger.info("Partition:" + record.partition()+",Offset:"+record.offset());
+          JSONObject obj_name = new JSONObject(record.value());
+          logger.info(String.format("ranapp message recieved \n-> %s \n", obj_name));
+
+          ANRInputMessage ANRInputMessage=null;
+          try {
+           logger.info(String.format("Parsing the incoming json object to ANRInputMessage class"));
+           ANRInputMessage = objectMapper.readValue(obj_name.toString(), ANRInputMessage.class);
+          } catch (Exception ex) {
+           logger.info(String.format(
+             "Invalid Message received . Exception while parsing JSON object -> %s",
+             ex.getLocalizedMessage()));
+
+           ex.printStackTrace();
+           return;
+          }
+          try {
+           logger.info(String.format("Invoking convertInputMessagetoANROutput Function"));
+           ANROutputMessage ANROutputMessage= convertInputMessagetoANROutput(ANRInputMessage);
+           logger.info(String.format("ANROutputMessage"));
+           logger.info(String.format(objectMapper.writeValueAsString(ANROutputMessage)));
+
+           // Output Payload is sent as Websocket message to RC
+           DeviceData devicedata=new DeviceData();
+           devicedata.setMessage(objectMapper.writeValueAsString(ANROutputMessage.getPayload()));
+           devicedata.setType(MessageType.KAFKA_MSG);
+           logger.info(String.format("Sending Output Payload to RC WS Server"));
+           websocketclient.sendMessage(devicedata);
+
+          } catch (Exception e) {
+           e.getLocalizedMessage();
+           e.printStackTrace();
+          }
+            }
+  }}catch (Exception e) {
+   e.getLocalizedMessage();
+   e.printStackTrace();
+  }
+ }
+ private ANROutputMessage convertInputMessagetoANROutput(ANRInputMessage ANRInputMessage) {
+  // TODO Auto-generated method stub
+  logger.info(String.format("Creating OutputMessage from ANRInput Function"));
+  ANROutputMessage ANROutputMessage=new ANROutputMessage();
+
+
+
+  logger.info(String.format("initializing output parameters"));
+  //initializing Output Params
+  PayloadOutput payloadOutput=new PayloadOutput();
+  List<Configuration> listconfiguration= new LinkedList<Configuration>();
+  Configuration configuration=new Configuration();
+  Data data=new Data();
+  FAPService fapservice=new FAPService();
+  CellConfig cellconfig=new CellConfig();
+  LTE lte=new LTE();
+  RAN ran=new RAN();
+  Common common=new Common();
+  NeighborListInUse neighbourlistinuse=new NeighborListInUse();
+  List<LTECell> listltecell=new LinkedList<LTECell>();
+
+
+
+  logger.info(String.format("Iterating Neighbour cells to validate KPI"));
+  // Parsing the payload.policydata into output message payload
+  common.setCellIdentity(ANRInputMessage.getPayload().getPolicyData().getCellID());
+  int length=ANRInputMessage.getPayload().getPolicyData().getNeighbours().size();
+  for(int i=0;i<length;i++) {
+   LTECell ltecell=new LTECell();
+   ltecell.setIdGNBCUCPFunction(ANRInputMessage.getPayload().getPolicyData().getNeighbours().get(i).getPNFName());
+   ltecell.setPlmnid(ANRInputMessage.getPayload().getPolicyData().getNeighbours().get(i).getPlmnid());
+   ltecell.setnRTCI(0);
+   ltecell.setIdNRCellRelation(ANRInputMessage.getPayload().getPolicyData().getNeighbours().get(i).getCellID());
+   //Identify KPI Measurement
+   if(ANRInputMessage.getPayload().getPolicyData().getNeighbours().get(i).getHoKpi1() < hokpiThreshold)
+    ltecell.setIsHOAllowed("true");
+   else
+    ltecell.setIsHOAllowed("false");
+   listltecell.add(ltecell);
+  }
+  neighbourlistinuse.setLTECell(listltecell);
+  neighbourlistinuse.setLTECellNumberOfEntries(Integer.toString(listltecell.size()));
+  ran.setCommon(common);
+  ran.setNeighborListInUse(neighbourlistinuse);
+  lte.setRan(ran);
+  cellconfig.setLte(lte);
+  fapservice.setIdNRCellCU(ANRInputMessage.getPayload().getPolicyData().getPNFName());
+  fapservice.setCellConfig(cellconfig);
+  data.setRicId(ANRInputMessage.getPayload().getRicId());
+  data.setFAPService(fapservice);
+  configuration.setData(data);
+  //how do we iterate in a standard way, currently working in a static way
+  listconfiguration.add(configuration);
+  payloadOutput.setConfigurations(listconfiguration);
+
+
+  ANROutputMessage.setPayload(payloadOutput);
+
+  logger.info(String.format("returning back output msg"));
+  return ANROutputMessage;
+ }
+
+}
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/ANRInputMessage.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/ANRInputMessage.java
new file mode 100644
index 0000000..6fc85ba
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/ANRInputMessage.java
@@ -0,0 +1,57 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"action",
+"payload",
+"policy_type_id",
+"policy_id"
+})
+@Generated("jsonschema2pojo")
+public class ANRInputMessage {
+@JsonProperty("policy_type_id")
+private String policyTypeId;
+@JsonProperty("policy_id")
+private String policyId;
+@JsonProperty("action")
+private String action;
+@JsonProperty("payload")
+private Payload payload;
+public String getPolicyTypeId() {
+ return policyTypeId;
+}
+public void setPolicyTypeId(String policyTypeId) {
+ this.policyTypeId = policyTypeId;
+}
+public String getPolicyId() {
+ return policyId;
+}
+public void setPolicyId(String policyId) {
+ this.policyId = policyId;
+}
+public String getAction() {
+ return action;
+}
+public void setAction(String action) {
+ this.action = action;
+}
+public Payload getPayload() {
+ return payload;
+}
+public void setPayload(Payload payload) {
+ this.payload = payload;
+}
+@Override
+public String toString() {
+ return "ANRInputMessage [policyTypeId=" + policyTypeId + ", policyId=" + policyId + ", action=" + action
+   + ", payload=" + payload + "]";
+}
+}
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/ANROutputMessage.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/ANROutputMessage.java
new file mode 100644
index 0000000..64c71bb
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/ANROutputMessage.java
@@ -0,0 +1,26 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"payload"
+})
+@Generated("jsonschema2pojo")
+public class ANROutputMessage {
+@JsonProperty("payload")
+private PayloadOutput payload;
+@JsonProperty("payload")
+public PayloadOutput getPayload() {
+return payload;
+}
+@JsonProperty("payload")
+public void setPayload(PayloadOutput payload) {
+this.payload = payload;
+}
+@Override
+public String toString() {
+ return "ANROutputMessage [payload=" + payload + "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Aai.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Aai.java
new file mode 100644
index 0000000..c1c92c3
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Aai.java
@@ -0,0 +1,65 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"generic-vnf.prov-status",
+"generic-vnf.is-closed-loop-disabled",
+"pnf.pnf-name"
+})
+@Generated("jsonschema2pojo")
+public class Aai {
+@JsonProperty("generic-vnf.prov-status")
+private String genericVnfProvStatus;
+@JsonProperty("generic-vnf.is-closed-loop-disabled")
+private String genericVnfIsClosedLoopDisabled;
+@JsonProperty("pnf.pnf-name")
+private String pnfPnfName;
+@JsonIgnore
+private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+@JsonProperty("generic-vnf.prov-status")
+public String getGenericVnfProvStatus() {
+return genericVnfProvStatus;
+}
+@JsonProperty("generic-vnf.prov-status")
+public void setGenericVnfProvStatus(String genericVnfProvStatus) {
+this.genericVnfProvStatus = genericVnfProvStatus;
+}
+@JsonProperty("generic-vnf.is-closed-loop-disabled")
+public String getGenericVnfIsClosedLoopDisabled() {
+return genericVnfIsClosedLoopDisabled;
+}
+@JsonProperty("generic-vnf.is-closed-loop-disabled")
+public void setGenericVnfIsClosedLoopDisabled(String genericVnfIsClosedLoopDisabled) {
+this.genericVnfIsClosedLoopDisabled = genericVnfIsClosedLoopDisabled;
+}
+@JsonProperty("pnf.pnf-name")
+public String getPnfPnfName() {
+return pnfPnfName;
+}
+@JsonProperty("pnf.pnf-name")
+public void setPnfPnfName(String pnfPnfName) {
+this.pnfPnfName = pnfPnfName;
+}
+@JsonAnyGetter
+public Map<String, Object> getAdditionalProperties() {
+return this.additionalProperties;
+}
+@JsonAnySetter
+public void setAdditionalProperty(String name, Object value) {
+this.additionalProperties.put(name, value);
+}
+@Override
+public String toString() {
+ return "Aai [genericVnfProvStatus=" + genericVnfProvStatus + ", genericVnfIsClosedLoopDisabled="
+   + genericVnfIsClosedLoopDisabled + ", pnfPnfName=" + pnfPnfName +
+    "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/AppDescriptorKafkaTemplate.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/AppDescriptorKafkaTemplate.java
new file mode 100644
index 0000000..38cc396
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/AppDescriptorKafkaTemplate.java
@@ -0,0 +1,29 @@
+package org.onap.ranapp.kafka.model.appmodels;
+public class AppDescriptorKafkaTemplate {
+private String requestType;
+
+
+ @Override
+ public String toString() {
+  return "AppDescriptorKafkaTemplate [requestType=" + requestType + ", plainText=" + plainText
+    + ", getRequestType()=" + getRequestType() + ", getPlainText()=" + getPlainText() + ", getClass()="
+    + getClass() + ", hashCode()=" + hashCode() + ", toString()=" + super.toString() + "]";
+ }
+ public AppDescriptorKafkaTemplate() {
+  super();
+  // TODO Auto-generated constructor stub
+ }
+ public String getRequestType() {
+  return requestType;
+ }
+ public void setRequestType(String requestType) {
+  this.requestType = requestType;
+ }
+ public String getPlainText() {
+  return plainText;
+ }
+ public void setPlainText(String plainText) {
+  this.plainText = plainText;
+ }
+ private String plainText;
+}
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/CellConfig.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/CellConfig.java
new file mode 100644
index 0000000..e861f4c
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/CellConfig.java
@@ -0,0 +1,31 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"LTE"
+})
+@Generated("jsonschema2pojo")
+public class CellConfig {
+@JsonProperty("LTE")
+private LTE lte;
+@JsonProperty("LTE")
+public LTE getLte() {
+return lte;
+}
+@JsonProperty("LTE")
+public void setLte(LTE lte) {
+this.lte = lte;
+}
+@Override
+public String toString() {
+ return "CellConfig [lte=" + lte +   "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Common.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Common.java
new file mode 100644
index 0000000..dbd6bc8
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Common.java
@@ -0,0 +1,31 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"CellIdentity"
+})
+@Generated("jsonschema2pojo")
+public class Common {
+@JsonProperty("CellIdentity")
+private String cellIdentity;
+@JsonProperty("CellIdentity")
+public String getCellIdentity() {
+return cellIdentity;
+}
+@JsonProperty("CellIdentity")
+public void setCellIdentity(String cellIdentity) {
+this.cellIdentity = cellIdentity;
+}
+@Override
+public String toString() {
+ return "Common [cellIdentity=" + cellIdentity +   "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Configuration.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Configuration.java
new file mode 100644
index 0000000..acfdbc5
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Configuration.java
@@ -0,0 +1,31 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"data"
+})
+@Generated("jsonschema2pojo")
+public class Configuration {
+@JsonProperty("data")
+private Data data;
+@JsonProperty("data")
+public Data getData() {
+return data;
+}
+@JsonProperty("data")
+public void setData(Data data) {
+this.data = data;
+}
+@Override
+public String toString() {
+ return "Configuration [data=" + data +   "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Data.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Data.java
new file mode 100644
index 0000000..7b403bb
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Data.java
@@ -0,0 +1,42 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"FAPService"
+})
+@Generated("jsonschema2pojo")
+public class Data {
+@JsonProperty("ric_id")
+private String ricId;
+
+@JsonProperty("FAPService")
+private FAPService fAPService;
+@JsonProperty("ric_id")
+public String getRicId() {
+ return ricId;
+}
+@JsonProperty("ric_id")
+public void setRicId(String ricId) {
+ this.ricId = ricId;
+}
+@JsonProperty("FAPService")
+public FAPService getFAPService() {
+return fAPService;
+}
+@JsonProperty("FAPService")
+public void setFAPService(FAPService fAPService) {
+this.fAPService = fAPService;
+}
+@Override
+public String toString() {
+ return "Data [ricId=" + ricId + ", fAPService=" + fAPService + "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/FAPService.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/FAPService.java
new file mode 100644
index 0000000..e53d50c
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/FAPService.java
@@ -0,0 +1,43 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"alias",
+"CellConfig"
+})
+@Generated("jsonschema2pojo")
+public class FAPService {
+@JsonProperty("idNRCellCU")
+private String idNRCellCU;
+@JsonProperty("CellConfig")
+private CellConfig cellConfig;
+@JsonProperty("idNRCellCU")
+public String getIdNRCellCU() {
+ return idNRCellCU;
+}
+@JsonProperty("idNRCellCU")
+public void setIdNRCellCU(String idNRCellCU) {
+ this.idNRCellCU = idNRCellCU;
+}
+@JsonProperty("CellConfig")
+public CellConfig getCellConfig() {
+return cellConfig;
+}
+@JsonProperty("CellConfig")
+public void setCellConfig(CellConfig cellConfig) {
+this.cellConfig = cellConfig;
+}
+@Override
+public String toString() {
+ return "FAPService [alias=" + idNRCellCU + ", cellConfig=" + cellConfig +
+    "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/LTE.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/LTE.java
new file mode 100644
index 0000000..2d0d3d0
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/LTE.java
@@ -0,0 +1,31 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"RAN"
+})
+@Generated("jsonschema2pojo")
+public class LTE {
+@JsonProperty("RAN")
+private RAN ran;
+@JsonProperty("RAN")
+public RAN getRan() {
+return ran;
+}
+@JsonProperty("RAN")
+public void setRan(RAN ran) {
+this.ran = ran;
+}
+@Override
+public String toString() {
+ return "LTE [ran=" + ran +   "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/LTECell.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/LTECell.java
new file mode 100644
index 0000000..2bc02bc
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/LTECell.java
@@ -0,0 +1,66 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"idGNBCUCPFunction",
+"PLMNID",
+"idNRCellRelation",
+"nRTCI",
+"isHOAllowed"
+})
+@Generated("jsonschema2pojo")
+public class LTECell {
+@JsonProperty("idGNBCUCPFunction")
+private String idGNBCUCPFunction;
+@JsonProperty("PLMNID")
+private String plmnid;
+@JsonProperty("idNRCellRelation")
+private String idNRCellRelation;
+@JsonProperty("nRTCI")
+private Integer nRTCI;
+@JsonProperty("isHOAllowed")
+private String isHOAllowed;
+public String getIdGNBCUCPFunction() {
+ return idGNBCUCPFunction;
+}
+public void setIdGNBCUCPFunction(String idGNBCUCPFunction) {
+ this.idGNBCUCPFunction = idGNBCUCPFunction;
+}
+public String getPlmnid() {
+ return plmnid;
+}
+public void setPlmnid(String plmnid) {
+ this.plmnid = plmnid;
+}
+public String getIdNRCellRelation() {
+ return idNRCellRelation;
+}
+public void setIdNRCellRelation(String idNRCellRelation) {
+ this.idNRCellRelation = idNRCellRelation;
+}
+public Integer getnRTCI() {
+ return nRTCI;
+}
+public void setnRTCI(Integer nRTCI) {
+ this.nRTCI = nRTCI;
+}
+public String getIsHOAllowed() {
+ return isHOAllowed;
+}
+public void setIsHOAllowed(String isHOAllowed) {
+ this.isHOAllowed = isHOAllowed;
+}
+@Override
+public String toString() {
+ return "LTECell [idGNBCUCPFunction=" + idGNBCUCPFunction + ", plmnid=" + plmnid + ", idNRCellRelation="
+   + idNRCellRelation + ", nRTCI=" + nRTCI + ", isHOAllowed=" + isHOAllowed + "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/NeighborListInUse.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/NeighborListInUse.java
new file mode 100644
index 0000000..bb1c33e
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/NeighborListInUse.java
@@ -0,0 +1,44 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"LTECell",
+"LTECellNumberOfEntries"
+})
+@Generated("jsonschema2pojo")
+public class NeighborListInUse {
+@JsonProperty("LTECell")
+private List<LTECell> lTECell = null;
+@JsonProperty("LTECellNumberOfEntries")
+private String lTECellNumberOfEntries;
+@JsonProperty("LTECell")
+public List<LTECell> getLTECell() {
+return lTECell;
+}
+@JsonProperty("LTECell")
+public void setLTECell(List<LTECell> lTECell) {
+this.lTECell = lTECell;
+}
+@JsonProperty("LTECellNumberOfEntries")
+public String getLTECellNumberOfEntries() {
+return lTECellNumberOfEntries;
+}
+@JsonProperty("LTECellNumberOfEntries")
+public void setLTECellNumberOfEntries(String lTECellNumberOfEntries) {
+this.lTECellNumberOfEntries = lTECellNumberOfEntries;
+}
+@Override
+public String toString() {
+ return "NeighborListInUse [lTECell=" + lTECell + ", lTECellNumberOfEntries=" + lTECellNumberOfEntries
+   +   "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Neighbour.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Neighbour.java
new file mode 100644
index 0000000..e4bf0f6
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Neighbour.java
@@ -0,0 +1,75 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"PNFName",
+"PLMNID",
+"CellID",
+"ho-kpi1"
+})
+@Generated("jsonschema2pojo")
+public class Neighbour {
+@JsonProperty("PNFName")
+private String pNFName;
+@JsonProperty("PLMNID")
+private String plmnid;
+@JsonProperty("CellID")
+private String cellID;
+@JsonProperty("ho-kpi1")
+private Integer hoKpi1;
+@JsonIgnore
+private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+@JsonProperty("PNFName")
+public String getPNFName() {
+return pNFName;
+}
+@JsonProperty("PNFName")
+public void setPNFName(String pNFName) {
+this.pNFName = pNFName;
+}
+@JsonProperty("PLMNID")
+public String getPlmnid() {
+return plmnid;
+}
+@JsonProperty("PLMNID")
+public void setPlmnid(String plmnid) {
+this.plmnid = plmnid;
+}
+@JsonProperty("CellID")
+public String getCellID() {
+return cellID;
+}
+@JsonProperty("CellID")
+public void setCellID(String cellID) {
+this.cellID = cellID;
+}
+@JsonProperty("ho-kpi1")
+public Integer getHoKpi1() {
+return hoKpi1;
+}
+@JsonProperty("ho-kpi1")
+public void setHoKpi1(Integer hoKpi1) {
+this.hoKpi1 = hoKpi1;
+}
+@JsonAnyGetter
+public Map<String, Object> getAdditionalProperties() {
+return this.additionalProperties;
+}
+@JsonAnySetter
+public void setAdditionalProperty(String name, Object value) {
+this.additionalProperties.put(name, value);
+}
+@Override
+public String toString() {
+ return "Neighbour [pNFName=" + pNFName + ", plmnid=" + plmnid + ", cellID=" + cellID + ", hoKpi1=" + hoKpi1
+   +   "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Payload.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Payload.java
new file mode 100644
index 0000000..c3c7f90
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/Payload.java
@@ -0,0 +1,86 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"action",
+"policy_id",
+"policy_type_id",
+"ric_id",
+"policy_data"
+})
+@Generated("jsonschema2pojo")
+public class Payload {
+@JsonProperty("action")
+private String action;
+@JsonProperty("policy_id")
+private Integer policyId;
+@JsonProperty("policy_type_id")
+private Integer policyTypeId;
+@JsonProperty("ric_id")
+private String ricId;
+@JsonProperty("policy_data")
+private PolicyData policyData;
+@JsonIgnore
+private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+@JsonProperty("action")
+public String getAction() {
+return action;
+}
+@JsonProperty("action")
+public void setAction(String action) {
+this.action = action;
+}
+@JsonProperty("policy_id")
+public Integer getPolicyId() {
+return policyId;
+}
+@JsonProperty("policy_id")
+public void setPolicyId(Integer policyId) {
+this.policyId = policyId;
+}
+@JsonProperty("policy_type_id")
+public Integer getPolicyTypeId() {
+return policyTypeId;
+}
+@JsonProperty("policy_type_id")
+public void setPolicyTypeId(Integer policyTypeId) {
+this.policyTypeId = policyTypeId;
+}
+@JsonProperty("ric_id")
+public String getRicId() {
+return ricId;
+}
+@JsonProperty("ric_id")
+public void setRicId(String ricId) {
+this.ricId = ricId;
+}
+@JsonProperty("policy_data")
+public PolicyData getPolicyData() {
+return policyData;
+}
+@JsonProperty("policy_data")
+public void setPolicyData(PolicyData policyData) {
+this.policyData = policyData;
+}
+@JsonAnyGetter
+public Map<String, Object> getAdditionalProperties() {
+return this.additionalProperties;
+}
+@JsonAnySetter
+public void setAdditionalProperty(String name, Object value) {
+this.additionalProperties.put(name, value);
+}
+@Override
+public String toString() {
+ return "Payload [action=" + action + ", policyId=" + policyId + ", policyTypeId=" + policyTypeId + ", ricId="
+   + ricId + ", policyData=" + policyData +   "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/PayloadOutput.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/PayloadOutput.java
new file mode 100644
index 0000000..0f3d42c
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/PayloadOutput.java
@@ -0,0 +1,32 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"Configurations"
+})
+@Generated("jsonschema2pojo")
+public class PayloadOutput {
+@JsonProperty("Configurations")
+private List<Configuration> configurations = null;
+@JsonProperty("Configurations")
+public List<Configuration> getConfigurations() {
+return configurations;
+}
+@JsonProperty("Configurations")
+public void setConfigurations(List<Configuration> configurations) {
+this.configurations = configurations;
+}
+@Override
+public String toString() {
+ return "PayloadOutput [configurations=" + configurations +   "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/PolicyData.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/PolicyData.java
new file mode 100644
index 0000000..6f53145
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/PolicyData.java
@@ -0,0 +1,76 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"PNFName",
+"PLMNID",
+"CellID",
+"neighbours"
+})
+@Generated("jsonschema2pojo")
+public class PolicyData {
+@JsonProperty("PNFName")
+private String pNFName;
+@JsonProperty("PLMNID")
+private String plmnid;
+@JsonProperty("CellID")
+private String cellID;
+@JsonProperty("neighbours")
+private List<Neighbour> neighbours = null;
+@JsonIgnore
+private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+@JsonProperty("PNFName")
+public String getPNFName() {
+return pNFName;
+}
+@JsonProperty("PNFName")
+public void setPNFName(String pNFName) {
+this.pNFName = pNFName;
+}
+@JsonProperty("PLMNID")
+public String getPlmnid() {
+return plmnid;
+}
+@JsonProperty("PLMNID")
+public void setPlmnid(String plmnid) {
+this.plmnid = plmnid;
+}
+@JsonProperty("CellID")
+public String getCellID() {
+return cellID;
+}
+@JsonProperty("CellID")
+public void setCellID(String cellID) {
+this.cellID = cellID;
+}
+@JsonProperty("neighbours")
+public List<Neighbour> getNeighbours() {
+return neighbours;
+}
+@JsonProperty("neighbours")
+public void setNeighbours(List<Neighbour> neighbours) {
+this.neighbours = neighbours;
+}
+@JsonAnyGetter
+public Map<String, Object> getAdditionalProperties() {
+return this.additionalProperties;
+}
+@JsonAnySetter
+public void setAdditionalProperty(String name, Object value) {
+this.additionalProperties.put(name, value);
+}
+@Override
+public String toString() {
+ return "PolicyData [pNFName=" + pNFName + ", plmnid=" + plmnid + ", cellID=" + cellID + ", neighbours=" + neighbours
+   +   "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/PolicytypetoTopicMapping.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/PolicytypetoTopicMapping.java
new file mode 100644
index 0000000..c6198d2
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/PolicytypetoTopicMapping.java
@@ -0,0 +1,31 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import com.fasterxml.jackson.annotation.JsonProperty;
+public class PolicytypetoTopicMapping {
+ @JsonProperty("request_topic")
+ private String request_topic;
+ @JsonProperty("response_topic")
+ private String response_topic;
+ @JsonProperty("request_topic")
+ public String getRequest_topic() {
+  return request_topic;
+ }
+ @JsonProperty("request_topic")
+ public void setRequest_topic(String request_topic) {
+  this.request_topic = request_topic;
+ }
+ @JsonProperty("response_topic")
+ public String getResponse_topic() {
+  return response_topic;
+ }
+ @JsonProperty("response_topic")
+ public void setResponse_topic(String response_topic) {
+  this.response_topic = response_topic;
+ }
+ @Override
+ public String toString() {
+  return "PolicytypetoTopicMapping [request_topic=" + request_topic + ", response_topic=" + response_topic + "]";
+ }
+
+
+
+}
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/RAN.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/RAN.java
new file mode 100644
index 0000000..e6d7287
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/RAN.java
@@ -0,0 +1,43 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import java.util.HashMap;
+import java.util.Map;
+import javax.annotation.Generated;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({
+"Common",
+"NeighborListInUse"
+})
+@Generated("jsonschema2pojo")
+public class RAN {
+@JsonProperty("Common")
+private Common common;
+@JsonProperty("Common")
+public Common getCommon() {
+return common;
+}
+@JsonProperty("Common")
+public void setCommon(Common common) {
+this.common = common;
+}
+@JsonProperty("NeighborListInUse")
+private NeighborListInUse neighborListInUse;
+@JsonProperty("NeighborListInUse")
+public NeighborListInUse getNeighborListInUse() {
+return neighborListInUse;
+}
+@JsonProperty("NeighborListInUse")
+public void setNeighborListInUse(NeighborListInUse neighborListInUse) {
+this.neighborListInUse = neighborListInUse;
+}
+@Override
+public String toString() {
+ return "RAN [common=" + common + ", neighborListInUse=" + neighborListInUse +
+    "]";
+}
+}
\ No newline at end of file
diff --git a/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/ResponsetoA1.java b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/ResponsetoA1.java
new file mode 100644
index 0000000..91fa7fe
--- /dev/null
+++ b/ANR-App/src/main/java/org/onap/ranapp/kafka/model/appmodels/ResponsetoA1.java
@@ -0,0 +1,30 @@
+package org.onap.ranapp.kafka.model.appmodels;
+import com.fasterxml.jackson.annotation.JsonProperty;
+public class ResponsetoA1 {
+ @Override
+ public String toString() {
+  return "{ \"response-code\":" + response_code + ", \"error-info\":\"" + error_info +"\"}";
+ }
+ @JsonProperty("response-code")
+ private int response_code;
+
+
+ @JsonProperty("error-info")
+ private String error_info;
+ @JsonProperty("response-code")
+ public int getResponse_code() {
+  return response_code;
+ }
+ @JsonProperty("response-code")
+ public void setResponse_code(int response_code) {
+  this.response_code = response_code;
+ }
+ @JsonProperty("error-info")
+ public String getError_info() {
+  return error_info;
+ }
+ @JsonProperty("error-info")
+ public void setError_info(String error_info) {
+  this.error_info = error_info;
+ }
+}