Modifier corrections for instance variables 99/27499/1
authorlibujacob <libu.jacob@huawei.com>
Fri, 5 Jan 2018 05:51:45 +0000 (11:21 +0530)
committerlibujacob <libu.jacob@huawei.com>
Fri, 5 Jan 2018 05:58:47 +0000 (11:28 +0530)
Removed toString() method for string datatypes

Issue-ID: DCAEGEN2-207

Change-Id: I24d45fa312808333df7c42b85c277baa708bfa35
Signed-off-by: libujacob <libu.jacob@huawei.com>
src/main/java/org/onap/dcae/commonFunction/CommonStartup.java
src/main/java/org/onap/dcae/restapi/RestfulCollectorServlet.java
src/main/java/org/onap/dcae/restapi/endpoints/EventReceipt.java

index 55a83f7..b4fae2a 100644 (file)
@@ -81,7 +81,7 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable {
        public static final String KDEFAULT_KEYALIAS = "tomcat";
 
        public static final String KSETTING_DMAAPCONFIGS = "collector.dmaapfile";
-       protected static final String[] KDEFAULT_DMAAPCONFIGS = new String[] { "/etc/DmaapConfig.json" };
+       private static final String[] KDEFAULT_DMAAPCONFIGS = new String[] { "/etc/DmaapConfig.json" };
 
        public static final String KSETTING_MAXQUEUEDEVENTS = "collector.inputQueue.maxPending";
        public static final int KDEFAULT_MAXQUEUEDEVENTS = 1024 * 4;
@@ -98,7 +98,7 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable {
        public static final String KSETTING_AUTHFLAG = "header.authflag";
        public static final int KDEFAULT_AUTHFLAG = 0;
 
-       public static final String kSetting_authlist = "header.authlist";
+       public static final String KSETTING_AUTHLIST = "header.authlist";
 
        public static final String KSETTING_EVENTTRANSFORMFLAG = "event.transform.flag";
        public static final int KDEFAULT_EVENTTRANSFORMFLAG = 1;
@@ -108,7 +108,7 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable {
        public static final Logger eplog = LoggerFactory.getLogger("org.onap.dcae.commonFunction.error");
        public static final Logger metriclog = LoggerFactory.getLogger("com.att.ecomp.metrics");
 
-       public static int schema_Validatorflag = -1;
+       public static int schemaValidatorflag = -1;
        public static int authflag = 1;
        public static int eventTransformFlag = 1;
        public static String schemaFile;
@@ -118,6 +118,10 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable {
        private boolean listnerstatus;
        public static String streamid;
 
+       public static LinkedBlockingQueue<JSONObject> fProcessingInputQueue;
+       private static ApiServer fTomcatServer = null;
+       private static final Logger log = LoggerFactory.getLogger(CommonStartup.class);
+
        private CommonStartup(rrNvReadable settings) throws loadException, IOException, rrNvReadable.missingReqdSetting,
                        rrNvReadable.invalidSettingValue, ServletException, InterruptedException {
                final List<ApiServerConnector> connectors = new LinkedList<ApiServerConnector>();
@@ -143,8 +147,8 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable {
 
                // Reading other config properties
 
-               schema_Validatorflag = settings.getInt(KSETTING_SCHEMAVALIDATOR, KDEFAULT_SCHEMAVALIDATOR);
-               if (schema_Validatorflag > 0) {
+               schemaValidatorflag = settings.getInt(KSETTING_SCHEMAVALIDATOR, KDEFAULT_SCHEMAVALIDATOR);
+               if (schemaValidatorflag > 0) {
                        schemaFile = settings.getString(KSETTING_SCHEMAFILE, KDEFAULT_SCHEMAFILE);
                        // System.out.println("SchemaFile:" + schemaFile);
                        schemaFileJson = new JSONObject(schemaFile);
@@ -280,14 +284,14 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable {
                        report = schema.validate(data);
                } catch (JsonParseException e) {
                        log.error("schemavalidate:JsonParseException for event:" + jsonData);
-                       return e.getMessage().toString();
+                       return e.getMessage();
                } catch (ProcessingException e) {
                        log.error("schemavalidate:Processing exception for event:" + jsonData);
-                       return e.getMessage().toString();
+                       return e.getMessage();
                } catch (IOException e) {
                        log.error(
                                        "schemavalidate:IO exception; something went wrong trying to read json data for event:" + jsonData);
-                       return e.getMessage().toString();
+                       return e.getMessage();
                }
                if (report != null) {
                        Iterator<ProcessingMessage> iter = report.iterator();
@@ -305,8 +309,5 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable {
                return result;
        }
 
-       public static LinkedBlockingQueue<JSONObject> fProcessingInputQueue;
-       private static ApiServer fTomcatServer = null;
-       private static final Logger log = LoggerFactory.getLogger(CommonStartup.class);
 
 }
index c18901d..1fa3c41 100644 (file)
@@ -57,7 +57,7 @@ public class RestfulCollectorServlet extends CommonServlet
        public RestfulCollectorServlet ( rrNvReadable settings ) throws loadException, missingReqdSetting
        {
                super ( settings, "collector", false );
-               authlist = settings.getString(CommonStartup.kSetting_authlist,null);
+               authlist = settings.getString(CommonStartup.KSETTING_AUTHLIST,null);
        }
 
 
index 5ee3b79..8d2ecaa 100644 (file)
@@ -125,7 +125,7 @@ public class EventReceipt extends NsaBaseEndpoint {
                        }
 
                        if (retkey != null || CommonStartup.authflag == 0) {
-                               if (CommonStartup.schema_Validatorflag > 0) {
+                               if (CommonStartup.schemaValidatorflag > 0) {
                                        if ((arrayFlag == 1) && (jsonObject.has("eventList") && (!jsonObject.has("event")))
                                                        || ((arrayFlag == 0) && (!jsonObject.has("eventList") && (jsonObject.has("event"))))) {
                                                fr = new FileReader(schemaFileVersion(vesVersion));