关闭mqtt重连

services/emqx-agent/main.go

@@ -240,9 +240,9 @@ func main() {
 		panic(err)
 	}
 	agent := NewAgent(sd)
-	err = sd.SubDevMsg(func(ctx context.Context) DevSubHandle {
-		return agent
-	})
+	//err = sd.SubDevMsg(func(ctx context.Context) DevSubHandle {
+	//	return agent
+	//})
 	if err != nil {
 		panic(err)
 	}