add MQTT outqueue back in (still broken)

This commit is contained in:
Thomas Göttgens
2023-01-04 14:41:58 +01:00
parent 30ae4c2a38
commit d9f0dc7ea4
2 changed files with 56 additions and 10 deletions

View File

@@ -13,6 +13,8 @@
#include <EthernetClient.h>
#endif
#define MAX_MQTT_QUEUE 32
/**
* Our wrapper/singleton for sending/receiving MQTT "udp" packets. This object isolates the MQTT protocol implementation from
* the two components that use it: MQTTPlugin and MQTTSimInterface.
@@ -53,9 +55,10 @@ class MQTT : private concurrency::OSThread
bool connected();
protected:
PointerQueue<ServiceEnvelope> mqttQueue;
int reconnectCount = 0;
virtual int32_t runOnce() override;
private: