diff options
author | 2022-09-14 18:04:56 +0530 | |
---|---|---|
committer | 2022-10-28 12:02:19 +0530 | |
commit | f94d8ec01991c9cfc8e4c74de2e763e72d4fbbbf (patch) | |
tree | d950078ceff5d702e263d965257643ce9ecd5eca /ANR-App/src/main/java/org/onap/ranapp/kafka | |
parent | 746cc0a4aa1ada72d98ed161322fb2bd1e359637 (diff) |
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
Diffstat (limited to 'ANR-App/src/main/java/org/onap/ranapp/kafka')
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; + } +} |