commit 279130df4db1c264fd0e2af167c630c264275d06
author Jian Li <pyguni@gmail.com> Wed Apr 06 16:29:44 2016 -0700
committer Gerrit Code Review <gerrit@onlab.us> Mon Apr 11 17:24:31 2016 +0000
tree 21fda1050e53c4d09e82900ef9299fda6e97a329
parent 7d4f2f7c8f193ef692d18fb810c2e6ec1c25b854

Handle reporting errors gracefully for various metrics reporters

Change-Id: Ifc928fa25732609ff185caf213467ee40bdb6f53

apps/influxdbmetrics/src/main/java/org/onosproject/influxdbmetrics/DefaultInfluxDbMetricsReporter.java

diff --git a/apps/influxdbmetrics/src/main/java/org/onosproject/influxdbmetrics/DefaultInfluxDbMetricsReporter.java b/apps/influxdbmetrics/src/main/java/org/onosproject/influxdbmetrics/DefaultInfluxDbMetricsReporter.java
index 7ff636c..a0dca3b 100644
--- a/apps/influxdbmetrics/src/main/java/org/onosproject/influxdbmetrics/DefaultInfluxDbMetricsReporter.java
+++ b/apps/influxdbmetrics/src/main/java/org/onosproject/influxdbmetrics/DefaultInfluxDbMetricsReporter.java
@@ -120,7 +120,12 @@
     public void startReport() {
         configSender();
         influxDbReporter = buildReporter(influxDbHttpSender);
-        influxDbReporter.start(REPORT_PERIOD, REPORT_TIME_UNIT);
+
+        try {
+            influxDbReporter.start(REPORT_PERIOD, REPORT_TIME_UNIT);
+        } catch (Exception e) {
+            log.error("Errors during reporting to InfluxDB, msg: {}" + e.getMessage());
+        }
         log.info("Start to report metrics to influxDB.");
     }
 
@@ -142,7 +147,13 @@
     public void notifyMetricsChange() {
         influxDbReporter.stop();
         influxDbReporter = buildReporter(influxDbHttpSender);
-        influxDbReporter.start(REPORT_PERIOD, REPORT_TIME_UNIT);
+
+        try {
+            influxDbReporter.start(REPORT_PERIOD, REPORT_TIME_UNIT);
+        } catch (Exception e) {
+            log.error("Errors during reporting to InfluxDB, msg: {}" + e.getMessage());
+        }
+
         log.info("Metric registry has been changed, apply changes.");
     }