昨天关闭开发环境

services/emqx-agent/client/mqtt_client.go

@@ -10,7 +10,6 @@ import (
 	"sparrow/pkg/server"
 
 	"sync"
-	"time"
 )
 
 var (
@@ -67,10 +66,10 @@ func initMqttClient(conf *MqttConfig) (mc MQTT.Client, err error) {
 	})
 
 	mc = MQTT.NewClient(opts)
-	if errF := mc.Connect().WaitTimeout(time.Second * 5); errF == false {
-		server.Log.Errorf("connected failed")
-		return
-	}
+	//if errF := mc.Connect().WaitTimeout(time.Second * 5); errF == false {
+	//	server.Log.Errorf("connected failed")
+	//	return
+	//}
 	return
 }