Code Review / dmaap / datarouter.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
Add RequestId and InvocationId to DR
[dmaap/datarouter.git] / datarouter-prov / src / main / java / org / onap / dmaap / datarouter / provisioning / LogServlet.java
diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/LogServlet.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/LogServlet.java
index cdc2331..eceab57 100644 (file)
--- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/LogServlet.java
+++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/LogServlet.java
@@ -64,7 +64,7 @@ import static org.onap.dmaap.datarouter.provisioning.utils.HttpServletUtils.send
 @SuppressWarnings("serial")\r
 public class LogServlet extends BaseServlet {\r
     //Adding EELF Logger Rally:US664892\r
-    private static EELFLogger eelflogger = EELFManager.getInstance().getLogger("org.onap.dmaap.datarouter.provisioning.LogServlet");\r
+    private static EELFLogger eelflogger = EELFManager.getInstance().getLogger(LogServlet.class);\r
     private static final long TWENTYFOUR_HOURS = (24 * 60 * 60 * 1000L);\r
     private static final String FMT_1 = "yyyy-MM-dd'T'HH:mm:ss'Z'";\r
     private static final String FMT_2 = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'";\r
@@ -147,14 +147,19 @@ public class LogServlet extends BaseServlet {
      */\r
     @Override\r
     public void doDelete(HttpServletRequest req, HttpServletResponse resp) {\r
-        setIpAndFqdnForEelf("doDelete");\r
-        eelflogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER),getIdFromPath(req)+"");\r
-        String message = "DELETE not allowed for the logURL.";\r
-        EventLogRecord elr = new EventLogRecord(req);\r
-        elr.setMessage(message);\r
-        elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
-        eventlogger.info(elr);\r
-        sendResponseError(resp, HttpServletResponse.SC_METHOD_NOT_ALLOWED, message, eventlogger);\r
+        setIpFqdnRequestIDandInvocationIDForEelf("doDelete", req);\r
+        eelflogger.info(EelfMsgs.ENTRY);\r
+        try {\r
+            eelflogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER), getIdFromPath(req) + "");\r
+            String message = "DELETE not allowed for the logURL.";\r
+            EventLogRecord elr = new EventLogRecord(req);\r
+            elr.setMessage(message);\r
+            elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
+            eventlogger.info(elr);\r
+            sendResponseError(resp, HttpServletResponse.SC_METHOD_NOT_ALLOWED, message, eventlogger);\r
+        } finally {\r
+        eelflogger.info(EelfMsgs.EXIT);\r
+    }\r
     }\r
     /**\r
      * GET a logging URL -- retrieve logging data for a feed or subscription.\r
@@ -162,64 +167,69 @@ public class LogServlet extends BaseServlet {
      */\r
     @Override\r
     public void doGet(HttpServletRequest req, HttpServletResponse resp) {\r
-        setIpAndFqdnForEelf("doGet");\r
-        eelflogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER),getIdFromPath(req)+"");\r
-        int id = getIdFromPath(req);\r
-        if (id < 0) {\r
-            sendResponseError(resp, HttpServletResponse.SC_BAD_REQUEST, "Missing or bad feed/subscription number.", eventlogger);\r
-            return;\r
-        }\r
-        Map<String, String> map = buildMapFromRequest(req);\r
-        if (map.get("err") != null) {\r
-            sendResponseError(resp, HttpServletResponse.SC_BAD_REQUEST, "Invalid arguments: "+map.get("err"), eventlogger);\r
-            return;\r
-        }\r
-        // check Accept: header??\r
+        setIpFqdnRequestIDandInvocationIDForEelf("doGet", req);\r
+        eelflogger.info(EelfMsgs.ENTRY);\r
+        try {\r
+            eelflogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER), getIdFromPath(req) + "");\r
+            int id = getIdFromPath(req);\r
+            if (id < 0) {\r
+                sendResponseError(resp, HttpServletResponse.SC_BAD_REQUEST, "Missing or bad feed/subscription number.", eventlogger);\r
+                return;\r
+            }\r
+            Map<String, String> map = buildMapFromRequest(req);\r
+            if (map.get("err") != null) {\r
+                sendResponseError(resp, HttpServletResponse.SC_BAD_REQUEST, "Invalid arguments: " + map.get("err"), eventlogger);\r
+                return;\r
+            }\r
+            // check Accept: header??\r
 \r
-        resp.setStatus(HttpServletResponse.SC_OK);\r
-        resp.setContentType(LOGLIST_CONTENT_TYPE);\r
+            resp.setStatus(HttpServletResponse.SC_OK);\r
+            resp.setContentType(LOGLIST_CONTENT_TYPE);\r
 \r
-        try (ServletOutputStream out = resp.getOutputStream()) {\r
-            final String fields = req.getParameter("fields");\r
+            try (ServletOutputStream out = resp.getOutputStream()) {\r
+                final String fields = req.getParameter("fields");\r
 \r
-            out.print("[");\r
-            if (isfeedlog) {\r
-                // Handle /feedlog/feedid request\r
-                boolean firstrow = true;\r
+                out.print("[");\r
+                if (isfeedlog) {\r
+                    // Handle /feedlog/feedid request\r
+                    boolean firstrow = true;\r
 \r
-                // 1. Collect publish records for this feed\r
-                RowHandler rh = new PublishRecordRowHandler(out, fields, firstrow);\r
-                getPublishRecordsForFeed(id, rh, map);\r
-                firstrow = rh.firstrow;\r
+                    // 1. Collect publish records for this feed\r
+                    RowHandler rh = new PublishRecordRowHandler(out, fields, firstrow);\r
+                    getPublishRecordsForFeed(id, rh, map);\r
+                    firstrow = rh.firstrow;\r
 \r
-                // 2. Collect delivery records for subscriptions to this feed\r
-                rh = new DeliveryRecordRowHandler(out, fields, firstrow);\r
-                getDeliveryRecordsForFeed(id, rh, map);\r
-                firstrow = rh.firstrow;\r
+                    // 2. Collect delivery records for subscriptions to this feed\r
+                    rh = new DeliveryRecordRowHandler(out, fields, firstrow);\r
+                    getDeliveryRecordsForFeed(id, rh, map);\r
+                    firstrow = rh.firstrow;\r
 \r
-                // 3. Collect expiry records for subscriptions to this feed\r
-                rh = new ExpiryRecordRowHandler(out, fields, firstrow);\r
-                getExpiryRecordsForFeed(id, rh, map);\r
-            } else {\r
-                // Handle /sublog/subid request\r
-                Subscription sub = Subscription.getSubscriptionById(id);\r
-                if (sub != null) {\r
-                    // 1. Collect publish records for the feed this subscription feeds\r
-                    RowHandler rh = new PublishRecordRowHandler(out, fields, true);\r
-                    getPublishRecordsForFeed(sub.getFeedid(), rh, map);\r
+                    // 3. Collect expiry records for subscriptions to this feed\r
+                    rh = new ExpiryRecordRowHandler(out, fields, firstrow);\r
+                    getExpiryRecordsForFeed(id, rh, map);\r
+                } else {\r
+                    // Handle /sublog/subid request\r
+                    Subscription sub = Subscription.getSubscriptionById(id);\r
+                    if (sub != null) {\r
+                        // 1. Collect publish records for the feed this subscription feeds\r
+                        RowHandler rh = new PublishRecordRowHandler(out, fields, true);\r
+                        getPublishRecordsForFeed(sub.getFeedid(), rh, map);\r
 \r
-                    // 2. Collect delivery records for this subscription\r
-                    rh = new DeliveryRecordRowHandler(out, fields, rh.firstrow);\r
-                    getDeliveryRecordsForSubscription(id, rh, map);\r
+                        // 2. Collect delivery records for this subscription\r
+                        rh = new DeliveryRecordRowHandler(out, fields, rh.firstrow);\r
+                        getDeliveryRecordsForSubscription(id, rh, map);\r
 \r
-                    // 3. Collect expiry records for this subscription\r
-                    rh = new ExpiryRecordRowHandler(out, fields, rh.firstrow);\r
-                    getExpiryRecordsForSubscription(id, rh, map);\r
+                        // 3. Collect expiry records for this subscription\r
+                        rh = new ExpiryRecordRowHandler(out, fields, rh.firstrow);\r
+                        getExpiryRecordsForSubscription(id, rh, map);\r
+                    }\r
                 }\r
+                out.print("]");\r
+            } catch (IOException ioe) {\r
+                eventlogger.error("IOException: " + ioe.getMessage());\r
             }\r
-            out.print("]");\r
-        } catch (IOException ioe) {\r
-            eventlogger.error("IOException: " + ioe.getMessage());\r
+        } finally {\r
+            eelflogger.info(EelfMsgs.EXIT);\r
         }\r
     }\r
     /**\r
@@ -227,7 +237,9 @@ public class LogServlet extends BaseServlet {
      */\r
     @Override\r
     public void doPut(HttpServletRequest req, HttpServletResponse resp) {\r
-        setIpAndFqdnForEelf("doPut");\r
+        setIpFqdnRequestIDandInvocationIDForEelf("doPut", req);\r
+        eelflogger.info(EelfMsgs.ENTRY);\r
+        try {\r
         eelflogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER),getIdFromPath(req)+"");\r
         String message = "PUT not allowed for the logURL.";\r
         EventLogRecord elr = new EventLogRecord(req);\r
@@ -235,13 +247,18 @@ public class LogServlet extends BaseServlet {
         elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
         eventlogger.info(elr);\r
         sendResponseError(resp, HttpServletResponse.SC_METHOD_NOT_ALLOWED, message, eventlogger);\r
+        } finally {\r
+            eelflogger.info(EelfMsgs.EXIT);\r
+        }\r
     }\r
     /**\r
      * POST a logging URL -- not supported.\r
      */\r
     @Override\r
     public void doPost(HttpServletRequest req, HttpServletResponse resp) {\r
-        setIpAndFqdnForEelf("doPost");\r
+        setIpFqdnRequestIDandInvocationIDForEelf("doPost", req);\r
+        eelflogger.info(EelfMsgs.ENTRY);\r
+        try {\r
         eelflogger.info(EelfMsgs.MESSAGE_WITH_BEHALF, req.getHeader(BEHALF_HEADER));\r
         String message = "POST not allowed for the logURL.";\r
         EventLogRecord elr = new EventLogRecord(req);\r
@@ -249,6 +266,9 @@ public class LogServlet extends BaseServlet {
         elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
         eventlogger.info(elr);\r
         sendResponseError(resp, HttpServletResponse.SC_METHOD_NOT_ALLOWED, message, eventlogger);\r
+        } finally {\r
+            eelflogger.info(EelfMsgs.EXIT);\r
+        }\r
     }\r
 \r
     private Map<String, String> buildMapFromRequest(HttpServletRequest req) {\r
The Data Routing System project is intended to provide a common framework by which data producers can make data available to data consumers and a way for potential consumers to find feeds with the data they require. The interface to DR is exposed as a RESTful web service known as the DR Publishing and Delivery API