commit ed5899897566b66340bba14ba6c5d6fc22d64797
author Jonathan Hart <jonomhart@gmail.com> Tue Feb 25 15:11:37 2020 -0800
committer Jonathan Hart <jonomhart@gmail.com> Tue Feb 25 15:11:51 2020 -0800
tree 7a95d13e50179d4b010f23c32de209aad739f9d2
parent ec08699b65d6ab9c29b34b91d381de2a48481e78

Lower log level of event logs

Change-Id: I5e24e9b94f9815e36f26e62b278f985fd065caf6

src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java

diff --git a/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java b/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
index 63cfb16..4d3a443 100644
--- a/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
+++ b/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
@@ -91,7 +91,7 @@
     private final RadiusOperationalStatusEventListener radiusOperationalStatusEventListener =
             new InternalRadiusOperationalStatusEventListener();
     private final AaaMachineStatisticsEventListener machineStatisticsEventListener =
-            new InternalAaaMachineStatisticsListner();
+            new InternalAaaMachineStatisticsListener();
 
     // topics
     private static final String TOPIC = "authentication.events";
@@ -204,17 +204,23 @@
 
     private void handleStat(AuthenticationStatisticsEvent event) {
         eventBusService.send(AUTHENTICATION_STATISTICS_TOPIC, serializeStat(event));
-        log.trace("AuthenticationStatisticsEvent sent successfully");
+        if (log.isTraceEnabled()) {
+            log.trace("AuthenticationStatisticsEvent sent successfully");
+        }
     }
 
     private void handleOperationalStatus(RadiusOperationalStatusEvent event) {
         eventBusService.send(RADIUS_OPERATION_STATUS_TOPIC, serializeOperationalStatus(event));
-        log.info("RadiusOperationalStatusEvent sent successfully");
+        if (log.isTraceEnabled()) {
+            log.trace("RadiusOperationalStatusEvent sent successfully");
+        }
     }
 
     private void handleMachineStat(AaaMachineStatisticsEvent machineStatEvent) {
         eventBusService.send(AUTHENTICATION_STATISTICS_TOPIC, serializeMachineStat(machineStatEvent));
-        log.info("MachineStatisticsEvent sent successfully");
+        if (log.isTraceEnabled()) {
+            log.trace("MachineStatisticsEvent sent successfully");
+        }
     }
 
     private JsonNode serialize(AuthenticationEvent event) {
@@ -231,7 +237,9 @@
     }
 
     private JsonNode serializeStat(AuthenticationStatisticsEvent event) {
-        log.trace("Serializing AuthenticationStatisticsEvent");
+        if (log.isTraceEnabled()) {
+            log.trace("Serializing AuthenticationStatisticsEvent");
+        }
         ObjectMapper mapper = new ObjectMapper();
         ObjectNode authMetricsEvent = mapper.createObjectNode();
         authMetricsEvent.put(TIMESTAMP, Instant.now().toString());
@@ -268,17 +276,20 @@
     }
 
     private JsonNode serializeOperationalStatus(RadiusOperationalStatusEvent event) {
-        log.info("Serializing RadiusOperationalStatusEvent");
+        if (log.isTraceEnabled()) {
+            log.trace("Serializing RadiusOperationalStatusEvent: {}", event.subject());
+        }
         ObjectMapper mapper = new ObjectMapper();
         ObjectNode authMetricsEvent = mapper.createObjectNode();
         authMetricsEvent.put(TIMESTAMP, Instant.now().toString());
-        log.info("---OPERATIONAL_STATUS----" + event.subject());
         authMetricsEvent.put(OPERATIONAL_STATUS, event.subject());
         return authMetricsEvent;
     }
 
     private JsonNode serializeMachineStat(AaaMachineStatisticsEvent machineStatEvent) {
-        log.info("Serializing AuthenticationStatisticsEvent");
+        if (log.isTraceEnabled()) {
+            log.trace("Serializing AuthenticationStatisticsEvent");
+        }
         ObjectMapper mapper = new ObjectMapper();
         ObjectNode machineStat = mapper.createObjectNode();
         AaaSupplicantMachineStats subject = machineStatEvent.subject();
@@ -334,7 +345,7 @@
         }
     }
 
-    private class InternalAaaMachineStatisticsListner implements AaaMachineStatisticsEventListener {
+    private class InternalAaaMachineStatisticsListener implements AaaMachineStatisticsEventListener {
 
         @Override
         public void event(AaaMachineStatisticsEvent machineStatEvent) {