更新订阅

services/emqx-agent/sub_dev.go

@@ -83,10 +83,10 @@ func newEmqClient(conf *client.MqttConfig) (SubDev, error) {
 
 func (d *MqttClient) SubDevMsg(handle Handle) error {
 
-	err := d.subDevMsg(nil, handle)
-	if err != nil {
-		return err
-	}
+	//err := d.subDevMsg(nil, handle)
+	//if err != nil {
+	//	return err
+	//}
 	client.SetMqttSetOnConnectHandler(func(cli mqtt.Client) {
 		err := d.subDevMsg(cli, handle)
 		if err != nil {