fix bug

services/mqttaccess/main.go

@@ -12,7 +12,7 @@ var deviceOnlineCount prometheus.Gauge
 var deviceMessageCount *prometheus.CounterVec
 
 func main() {
-	
+
 	// init server
 	err := server.Init(rpcs.MQTTAccessName)
 	if err != nil {
@@ -40,23 +40,23 @@ func main() {
 		return
 	}
 
-	deviceOnlineMetric := &server.Metric{
-		ID:          "device_online_count",
-		Name:        "device_online_count",
-		Description: "MQTT Device Online Count",
-		Type:        "gauge",
-	}
-	recvMessageCount := &server.Metric{
-		ID:          "device_message_total",
-		Name:        "device_message_total",
-		Description: "device report message total count",
-		Type:        "counter_vec",
-		Args:        []string{"device_code"},
-	}
-
-	server.RegisterMetric(deviceOnlineMetric, recvMessageCount)
-	deviceOnlineCount = deviceOnlineMetric.MetricCollector.(prometheus.Gauge)
-	deviceMessageCount = recvMessageCount.MetricCollector.(*prometheus.CounterVec)
+	//deviceOnlineMetric := &server.Metric{
+	//	ID:          "device_online_count",
+	//	Name:        "device_online_count",
+	//	Description: "MQTT Device Online Count",
+	//	Type:        "gauge",
+	//}
+	//recvMessageCount := &server.Metric{
+	//	ID:          "device_message_total",
+	//	Name:        "device_message_total",
+	//	Description: "device report message total count",
+	//	Type:        "counter_vec",
+	//	Args:        []string{"device_code"},
+	//}
+	//
+	//server.RegisterMetric(deviceOnlineMetric, recvMessageCount)
+	//deviceOnlineCount = deviceOnlineMetric.MetricCollector.(prometheus.Gauge)
+	//deviceMessageCount = recvMessageCount.MetricCollector.(*prometheus.CounterVec)
 
 	go func() {
 		pprofPort := "6060"