DigitalInfinity/ESP32-PaxCounter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

mqttclient small fix

Browse Source
This commit is contained in:
Klaus K Wilting 2020-10-10 00:49:55 +02:00
parent b5502f9edb
commit 2ff80fa360
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/mqttclient.cpp
View File

@ -16,8 +16,8 @@ esp_err_t mqtt_init(void) {
// setup network connection // setup network connection
WiFi.onEvent(NetworkEvent); WiFi.onEvent(NetworkEvent);
ETH.begin(); ETH.begin();
//WiFi.mode(WIFI_STA); // WiFi.mode(WIFI_STA);
//WiFi.begin("SSID", "PASSWORD"); // WiFi.begin("SSID", "PASSWORD");
// setup mqtt client // setup mqtt client
mqttClient.begin(MQTT_SERVER, MQTT_PORT, netClient); mqttClient.begin(MQTT_SERVER, MQTT_PORT, netClient);
@ -69,6 +69,8 @@ int mqtt_connect(const char *my_host, const uint16_t my_port) {
ESP_LOGW(TAG, "MQTT server not responding, retrying later"); ESP_LOGW(TAG, "MQTT server not responding, retrying later");
return -1; return -1;
} }
return 0;
} }
void NetworkEvent(WiFiEvent_t event) { void NetworkEvent(WiFiEvent_t event) {
@ -122,7 +124,7 @@ void mqtt_client_task(void *param) {
if (mqttClient.connected()) { if (mqttClient.connected()) {
char buffer[PAYLOAD_BUFFER_SIZE + 3]; char buffer[PAYLOAD_BUFFER_SIZE + 3];
snprintf(buffer, msg.MessageSize + 3, "%s/%s", msg.MessagePort, snprintf(buffer, msg.MessageSize + 3, "%s/%u", msg.MessagePort,
msg.Message); msg.Message);
if (mqttClient.publish(MQTT_OUTTOPIC, buffer)) { if (mqttClient.publish(MQTT_OUTTOPIC, buffer)) {