MQTT

[branka5]

Hi,

I have recently started with this great project.

So I am wondering if MQTT is already implemented as I have seen in folder lib some coments.

If so can you please advice how to integrate / configure this?

Many thanks.

[womoak75]

you have to add a build flag -DMQTT_ENABLE
see main.cpp

#ifdef MQTT_ENABLE   
#include <MQTT.h>   
#endif

[rashmikanaveen]

#include <PubSubClient.h>
#include <WiFi.h>

WiFiClient espClient;
PubSubClient mqttClient(espClient);

void setupMQTT(){
mqttClient.setServer("broker", port);
mqttClient.setCallback(receviveCallback);

}

void connectToBroker(){
while(!mqttClient.connected()){
Serial.println("Connecting to MQTT Broker...");
if(mqttClient.connect("ESP32-123456")){
Serial.println("Connected to MQTT Broker");
mqttClient.subscribe("topic");

}else{
  Serial.print("Failed to connect, rc=");
  Serial.print(mqttClient.state());
  delay(500);
}

}

}

void receviveCallback(char* topic, byte* payload, unsigned int length) {

Serial.print("Message arrived [");
Serial.print(topic);
Serial.print("] ");

char payloadCharAr[length + 1]; // Add space for null terminator
for (int i = 0; i < length; i++) {
Serial.print((char)payload[i]);
payloadCharAr[i] = (char)payload[i];
}
payloadCharAr[length] = '\0'; // Null-terminate the string
Serial.println();

}

}

[Meins321]

if that works maybe create a request to update it into the build? :)