SubDevMsg

services/emqx-agent/sub_dev.go

@@ -83,16 +83,16 @@ func newEmqClient(conf *client.MqttConfig) (SubDev, error) {
 
 func (d *MqttClient) SubDevMsg(handle Handle) error {
 
-	//err := d.subDevMsg(nil, handle)
-	//if err != nil {
-	//	return err
-	//}
-	client.SetMqttSetOnConnectHandler(func(cli mqtt.Client) {
-		err := d.subDevMsg(cli, handle)
-		if err != nil {
-			server.Log.Errorf("mqttSetOnConnectHandler.subDevMsg err:%v", 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 {
+	//		server.Log.Errorf("mqttSetOnConnectHandler.subDevMsg err:%v", err)
+	//	}
+	//})
 	return nil
 }