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: "));