commit 16f1f5337736bb93cbc8e3b33298c55a554368d6
author Jian Li <pyguni@gmail.com> Thu Dec 27 17:45:09 2018 +0900
committer Jian Li <pyguni@gmail.com> Wed Jan 09 05:37:17 2019 +0000
tree 74f79d9f0f9b2c73224c8f9fb9528a7fbc416756
parent 69600e0b76430edde22fade0e63d1cb94d60799e

Added a set of CLIs for update and enable/disable telemetry svc cfg

Change-Id: I518585f7941c98aa0479acc3583a0f1a751e6db9

apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryManager.java

diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryManager.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryManager.java
index 796da19..781c4e2 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryManager.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryManager.java
@@ -15,6 +15,7 @@
  */
 package org.onosproject.openstacktelemetry.impl;
 
+import com.google.common.collect.Maps;
 import org.influxdb.InfluxDB;
 import org.influxdb.InfluxDBFactory;
 import org.influxdb.dto.BatchPoints;
@@ -80,7 +81,7 @@
     protected TelemetryConfigService telemetryConfigService;
 
     private static final String INFLUX_PROTOCOL = "http";
-    private Map<String, InfluxDB> producers = null;
+    private Map<String, InfluxDB> producers = Maps.newConcurrentMap();
 
     @Activate
     protected void activate() {