SubDevMsg

services/emqx-agent/sub_dev.go

@@ -98,7 +98,9 @@ func (d *MqttClient) SubDevMsg(handle Handle) error {
 
 func (d *MqttClient) subDevMsg(cli mqtt.Client, handle Handle) error {
 	err := d.subscribeWithFunc(cli, TopicConnectStatus, d.subConnectStatus(handle))
+	server.Log.Infof("subDevMsg")
 	if err != nil {
+		server.Log.Infof("subDevMsg err:%v", err)
 		return err
 	}
 	err = d.subscribeWithFunc(cli, TopicThing, func(ctx context.Context, topic string, payload []byte) error {