pohui_pohui/firmware
1
0
Fork 0
mirror of https://github.com/meshtastic/firmware.git synced 2025-06-13 16:42:07 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

trybuildfix mqtt system

Browse Source
This commit is contained in:
Thomas Göttgens 2023-01-03 22:09:35 +01:00
parent 42b24d4510
commit 5867038abf
2 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/mqtt/MQTT.cpp
View File

@ -274,9 +274,9 @@ void MQTT::onSend(const MeshPacket &mp, ChannelIndex chIndex)
const char *channelId = channels.getGlobalId(chIndex); // FIXME, for now we just use the human name for the channel const char *channelId = channels.getGlobalId(chIndex); // FIXME, for now we just use the human name for the channel
ServiceEnvelope env = ServiceEnvelope_init_default; ServiceEnvelope env = ServiceEnvelope_init_default;
env->channel_id = (char *)channelId; env.channel_id = (char *)channelId;
env->gateway_id = owner.id; env.gateway_id = owner.id;
env->packet = (MeshPacket *)∓ env.packet = (MeshPacket *)∓
// don't bother sending if not connected... // don't bother sending if not connected...
if (pubSub.connected()) { if (pubSub.connected()) {

6
src/mqtt/MQTT.h
View File

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