From bbc8950ccb9504e8e531c2bdc759776b88aec443 Mon Sep 17 00:00:00 2001 From: Niels <7136117+TheDutchDev@users.noreply.github.com> Date: Thu, 4 Jan 2024 09:22:33 +0100 Subject: [PATCH] Update mqttmanager.h Move method above mqttCallback to fix not declared error --- src/mqttmanager.h | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/src/mqttmanager.h b/src/mqttmanager.h index 829f97f..b70f466 100644 --- a/src/mqttmanager.h +++ b/src/mqttmanager.h @@ -139,17 +139,6 @@ void ParseCallback(JsonDocument &messageobject){ } } -void mqttCallback(char *topic, byte *payload, unsigned int length){ - DynamicJsonDocument messageobject(mqttdocument); - - auto deserializeError = deserializeJson(messageobject, payload, length, DeserializationOption::Filter(getMqttPayloadFilter())); - if (!deserializeError){ - ParseCallback(messageobject); - }else{ - Serial.println(F("Deserialize error while parsing mqtt")); - } -} - StaticJsonDocument<64> getMqttPayloadFilter() { StaticJsonDocument<64> filter; @@ -161,6 +150,17 @@ StaticJsonDocument<64> getMqttPayloadFilter() return filter; } +void mqttCallback(char *topic, byte *payload, unsigned int length){ + DynamicJsonDocument messageobject(mqttdocument); + + auto deserializeError = deserializeJson(messageobject, payload, length, DeserializationOption::Filter(getMqttPayloadFilter())); + if (!deserializeError){ + ParseCallback(messageobject); + }else{ + Serial.println(F("Deserialize error while parsing mqtt")); + } +} + void setupMqtt(){ clientId += String(random(0xffff), HEX); Serial.println(F("Setting up MQTT with ip: "));