更新订阅

services/emqx-agent/sub_dev.go

@@ -101,7 +101,7 @@ func (d *MqttClient) subDevMsg(cli mqtt.Client, handle Handle) error {
 	if err != nil {
 		return err
 	}
-	err = d.subscribeWithFunc(cli, "TopicThing", func(ctx context.Context, topic string, payload []byte) error {
+	err = d.subscribeWithFunc(cli, TopicThing, func(ctx context.Context, topic string, payload []byte) error {
 		return handle(ctx).Message(topic, payload)
 	})
 	if err != nil {
@@ -113,7 +113,7 @@ func (d *MqttClient) subDevMsg(cli mqtt.Client, handle Handle) error {
 	//if err != nil {
 	//	return err
 	//}
-	err = d.subscribeWithFunc(cli, "TopicOta", func(ctx context.Context, topic string, payload []byte) error {
+	err = d.subscribeWithFunc(cli, TopicOta, func(ctx context.Context, topic string, payload []byte) error {
 		return handle(ctx).Message(topic, payload)
 	})
 	if err != nil {