commit 0f2449c5879a96557e809e42fde596efc7168c68
author Ganesh Bhure <ganesh.bhure@sterlite.com> Mon Jul 15 10:31:38 2019 +0530
committer Ganesh Bhure <ganesh.bhure@sterlite.com> Thu Aug 15 20:50:09 2019 +0530
tree d0eae15d2d2e77cae14cb3aca0ba8d3e694c324b
parent 967018e7d8478f3c846354440fc942c4d2881eaf

SEBA-794:update-exporter-for-promhttp

Change-Id: Ia16a5efc484dc27821873e09106bf3770d2b74fd

topic-exporter.go

diff --git a/topic-exporter.go b/topic-exporter.go
index 1713cfc..c306975 100644
--- a/topic-exporter.go
+++ b/topic-exporter.go
@@ -540,6 +540,7 @@
 		err := json.Unmarshal(data, &kpi)
 		if err != nil {
 			logger.Error("Invalid msg on voltha.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data))
+			break
 		}
 		exportVolthaKPI(kpi)
 	case "onos.kpis":
@@ -547,6 +548,7 @@
 		err := json.Unmarshal(data, &kpi)
 		if err != nil {
 			logger.Error("Invalid msg on onos.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data))
+			break
 		}
 		exportOnosKPI(kpi)
 	case "importer.kpis":
@@ -554,6 +556,7 @@
 		err := json.Unmarshal(data, &kpi)
 		if err != nil {
 			logger.Error("Invalid msg on importer.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data))
+			break
 		}
 		exportImporterKPI(kpi)
 	case "onos.aaa.stats.kpis":
@@ -561,6 +564,7 @@
 		err := json.Unmarshal(data, &kpi)
 		if err != nil {
 			logger.Error("Invalid msg on onos.aaa.stats.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data))
+			break
 		}
 		exportOnosAaaKPI(kpi)
 	default: