correct MQTT connection issue with arduino boards
This commit is contained in:
1 parent
02d959a25e
commit
f0648f481f
1 file changed
+19
-18
+19
-18
@@ -194,24 +194,8 @@ void setup()
|
|||||||
else if (error == OTA_END_ERROR) trc(F("End Failed"));
|
else if (error == OTA_END_ERROR) trc(F("End Failed"));
|
||||||
});
|
});
|
||||||
ArduinoOTA.begin();
|
ArduinoOTA.begin();
|
||||||
|
|
||||||
#ifdef MDNS_SD
|
#else // arduino case
|
||||||
trc(F("Connecting to MQTT by mDNS without mqtt hostname"));
|
|
||||||
connectMQTTmdns();
|
|
||||||
#else
|
|
||||||
#ifdef mqtt_server_name // if name is defined we define the mqtt server by its name
|
|
||||||
trc(F("Connecting to MQTT with mqtt hostname"));
|
|
||||||
IPAddress mqtt_server_ip;
|
|
||||||
WiFi.hostByName(mqtt_server_name, mqtt_server_ip);
|
|
||||||
client.setServer(mqtt_server_ip, mqtt_port);
|
|
||||||
trc(mqtt_server_ip.toString());
|
|
||||||
#else // if not by its IP adress
|
|
||||||
trc(F("Connecting to MQTT by IP adress"));
|
|
||||||
client.setServer(mqtt_server, mqtt_port);
|
|
||||||
trc(String(mqtt_server));
|
|
||||||
#endif
|
|
||||||
#endif
|
|
||||||
#else
|
|
||||||
//Launch serial for debugging purposes
|
//Launch serial for debugging purposes
|
||||||
Serial.begin(SERIAL_BAUD);
|
Serial.begin(SERIAL_BAUD);
|
||||||
//Begining ethernet connection in case of Arduino + W5100
|
//Begining ethernet connection in case of Arduino + W5100
|
||||||
@@ -228,6 +212,23 @@ void setup()
|
|||||||
digitalWrite(led_send, HIGH);
|
digitalWrite(led_send, HIGH);
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
#ifdef MDNS_SD
|
||||||
|
trc(F("Connecting to MQTT by mDNS without mqtt hostname"));
|
||||||
|
connectMQTTmdns();
|
||||||
|
#else
|
||||||
|
#ifdef mqtt_server_name // if name is defined we define the mqtt server by its name
|
||||||
|
trc(F("Connecting to MQTT with mqtt hostname"));
|
||||||
|
IPAddress mqtt_server_ip;
|
||||||
|
WiFi.hostByName(mqtt_server_name, mqtt_server_ip);
|
||||||
|
client.setServer(mqtt_server_ip, mqtt_port);
|
||||||
|
trc(mqtt_server_ip.toString());
|
||||||
|
#else // if not by its IP adress
|
||||||
|
trc(F("Connecting to MQTT by IP adress"));
|
||||||
|
client.setServer(mqtt_server, mqtt_port);
|
||||||
|
trc(String(mqtt_server));
|
||||||
|
#endif
|
||||||
|
#endif
|
||||||
|
|
||||||
client.setCallback(callback);
|
client.setCallback(callback);
|
||||||
|
|
||||||
delay(1500);
|
delay(1500);
|
||||||
|
|||||||
Reference in new issue
Block a user