更新订阅

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 {