update DR logging to log under one system

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

diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java
index 6c5a13f..8223188 100644 (file)
--- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java
+++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java
@@ -46,7 +46,8 @@ import java.util.Map;
 import java.util.TreeSet;\r
 import java.util.zip.GZIPInputStream;\r
 \r
-import org.apache.log4j.Logger;\r
+import com.att.eelf.configuration.EELFLogger;\r
+import com.att.eelf.configuration.EELFManager;\r
 import org.onap.dmaap.datarouter.provisioning.BaseServlet;\r
 import org.onap.dmaap.datarouter.provisioning.beans.DeliveryExtraRecord;\r
 import org.onap.dmaap.datarouter.provisioning.beans.DeliveryRecord;\r
@@ -106,7 +107,7 @@ public class LogfileLoader extends Thread {
      */\r
     private static final long SET_SIZE = (1L << 56);\r
 \r
-    private final Logger logger;\r
+    private final EELFLogger logger;\r
     private final DB db;\r
     private final String spooldir;\r
     private final long set_start;\r
@@ -116,7 +117,7 @@ public class LogfileLoader extends Thread {
     private boolean idle;\r
 \r
     private LogfileLoader() {\r
-        this.logger = Logger.getLogger("org.onap.dmaap.datarouter.provisioning.internal");\r
+        this.logger = EELFManager.getInstance().getLogger("InternalLog");\r
         this.db = new DB();\r
         this.spooldir = db.getProperties().getProperty("org.onap.dmaap.datarouter.provserver.spooldir");\r
         this.set_start = getIdRange();\r
@@ -274,7 +275,7 @@ public class LogfileLoader extends Thread {
              }\r
             } catch (SQLException e) {\r
                 System.err.println(e);\r
-                logger.error(e);\r
+                logger.error(e.toString());\r
             } finally {\r
                 db.release(conn);\r
             }\r
@@ -296,7 +297,7 @@ public class LogfileLoader extends Thread {
            }\r
          } catch (SQLException e) {\r
             System.err.println(e);\r
-            logger.error(e);\r
+            logger.error(e.toString());\r
         } finally {\r
             db.release(conn);\r
         }\r
@@ -321,7 +322,7 @@ public class LogfileLoader extends Thread {
             }\r
            } catch (SQLException e) {\r
             System.err.println(e);\r
-            logger.error(e);\r
+            logger.error(e.toString());\r
         } finally {\r
             db.release(conn);\r
         }\r
@@ -375,7 +376,7 @@ public class LogfileLoader extends Thread {
             logger.debug(String.format("initializeNextid, next ID is %d (%x)", nextid, nextid));\r
         } catch (SQLException e) {\r
             System.err.println(e);\r
-            logger.error(e);\r
+            logger.error(e.toString());\r
         } finally {\r
             db.release(conn);\r
         }\r
@@ -415,16 +416,16 @@ public class LogfileLoader extends Thread {
                         }\r
                     } catch (SQLException e) {\r
                         logger.warn("PROV8003 Invalid value in record: " + line);\r
-                        logger.debug(e);\r
+                        logger.debug(e.toString());\r
                     } catch (NumberFormatException e) {\r
                         logger.warn("PROV8004 Invalid number in record: " + line);\r
-                        logger.debug(e);\r
+                        logger.debug(e.toString());\r
                     } catch (ParseException e) {\r
                         logger.warn("PROV8005 Invalid date in record: " + line);\r
-                        logger.debug(e);\r
+                        logger.debug(e.toString());\r
                     } catch (Exception e) {\r
                         logger.warn("PROV8006 Invalid pattern in record: " + line);\r
-                        logger.debug(e);\r
+                        logger.debug(e.toString());\r
                     }\r
                     total++;\r
                 }\r