#include<Adafruit_MQTT.h>
#include<Adafruit_MQTT_Client.h>
#include<WiFi.h>
#include<WiFiClient.h>
#define server "io.adafruit.com"
#define port 1883
#define usr "aang_tejas"
#define key "aio_vlHi13FwtccEcxX8UNuhsE1Z3qpy"
WiFiClient tejas;
Adafruit_MQTT_Client mqtt(&tejas,server,port,usr,key);
Adafruit_MQTT_Subscribe tempu = Adafruit_MQTT_Subscribe(&mqtt,"aang_tejas/feeds/temp");
void setup(){
Serial1.begin(115200);
WiFi.begin("Wokwi-GUEST", "");
while (WiFi.status() != WL_CONNECTED) {
delay(1000);
Serial1.println("Connecting to WiFi...");
}
Serial1.println("Connected to WiFi!");
Serial1.print("IP : ");
Serial1.println(WiFi.localIP());
mqtt.subscribe(&tempu);
mqtt_check();
}
void loop(){
mqtt_check();
Adafruit_MQTT_Subscribe *value;
while(value = mqtt.readSubscription(6000)){
if (value == &tempu){
Serial1.print("Temp : ");
Serial1.println((char*)tempu.lastread);
}
}
}
void mqtt_check(){
if(mqtt.connected()){
Serial1.println("MQTT Conected !");
return;
}
int8_t ret;
while((ret = mqtt.connect())!=0){
Serial1.println("Retrying Connection .......");
mqtt.disconnect();
delay(1000);
}
}