update DR logging to log under one system

[dmaap/datarouter.git] / datarouter-prov / src / main / java / org / onap / dmaap / datarouter / provisioning / utils / DB.java

diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/DB.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/DB.java
index 8ca7118..d29876f 100644 (file)
--- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/DB.java
+++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/DB.java
@@ -41,7 +41,9 @@ import java.util.NoSuchElementException;
 import java.util.Properties;\r
 import java.util.Queue;\r
 import java.util.Set;\r
-import org.apache.log4j.Logger;\r
+\r
+import com.att.eelf.configuration.EELFLogger;\r
+import com.att.eelf.configuration.EELFManager;\r
 \r
 /**\r
  * Load the DB JDBC driver, and manage a simple pool of connections to the DB.\r
@@ -51,8 +53,7 @@ import org.apache.log4j.Logger;
  */\r
 public class DB {\r
 \r
-    private static Logger intlogger = Logger\r
-        .getLogger("org.onap.dmaap.datarouter.provisioning.internal");\r
+    private static EELFLogger intlogger = EELFManager.getInstance().getLogger("InternalLog");\r
 \r
     private static String DB_URL;\r
     private static String DB_LOGIN;\r
@@ -83,10 +84,10 @@ public class DB {
                 HTTP_PORT = (String) props.get("org.onap.dmaap.datarouter.provserver.http.port");\r
                 Class.forName(DB_DRIVER);\r
             } catch (IOException e) {\r
-                intlogger.fatal("PROV9003 Opening properties: " + e.getMessage());\r
+                intlogger.error("PROV9003 Opening properties: " + e.getMessage());\r
                 System.exit(1);\r
             } catch (ClassNotFoundException e) {\r
-                intlogger.fatal("PROV9004 cannot find the DB driver: " + e);\r
+                intlogger.error("PROV9004 cannot find the DB driver: " + e);\r
                 System.exit(1);\r
             }\r
         }\r
@@ -194,7 +195,7 @@ public class DB {
             }\r
         } catch (SQLException e) {\r
             intlogger\r
-                .fatal("PROV9000: The database credentials are not working: " + e.getMessage());\r
+                .error("PROV9000: The database credentials are not working: " + e.getMessage());\r
             return false;\r
         } finally {\r
             if (connection != null) {\r
@@ -222,7 +223,7 @@ public class DB {
                 rs.close();\r
             }\r
         } catch (SQLException e) {\r
-            intlogger.fatal("PROV9010: Failed to get TABLE data from DB: " + e.getMessage());\r
+            intlogger.error("PROV9010: Failed to get TABLE data from DB: " + e.getMessage());\r
         }\r
         return tables;\r
     }\r
@@ -241,7 +242,7 @@ public class DB {
         try {\r
             String scriptFile = String.format("%s/sql_init_%02d.sql", scriptDir, scriptId);\r
             if (!(new File(scriptFile)).exists()) {\r
-                intlogger.fatal("PROV9005 Failed to load sql script from : " + scriptFile);\r
+                intlogger.error("PROV9005 Failed to load sql script from : " + scriptFile);\r
                 System.exit(1);\r
             }\r
             LineNumberReader lineReader = new LineNumberReader(new FileReader(scriptFile));\r
@@ -263,7 +264,7 @@ public class DB {
             lineReader.close();\r
             strBuilder.setLength(0);\r
         } catch (Exception e) {\r
-            intlogger.fatal("PROV9002 Error when initializing table: " + e.getMessage());\r
+            intlogger.error("PROV9002 Error when initializing table: " + e.getMessage());\r
             System.exit(1);\r
         }\r
     }\r