Jack Hansdampf / ESP8266MQTT

Library for ESP8266 STM32 Nucleo F103RB L152RE

Dependencies:   mbed-mqtt-GSOE1

Dependents:   mqtt_Autofaehrschiff MQTT_Nucleo_dht11 mqtt_Testprogramm_FritzBox mqtt_TestprogrammWorkshop ... more

PubSubClient.h@7:c504822dc073, 2021-08-19 (annotated)

Committer:
jack1930
Date:
Thu Aug 19 10:26:44 2021 +0000
Revision:
7:c504822dc073
Parent:
6:d5d3b2bcb9b8 
QOS2

Who changed what in which revision?

UserRevisionLine numberNew contents of line
jack1930 0:a655fd59ed71 1 #include "mbed.h"
jack1930 0:a655fd59ed71 2 #include "ESP8266Interface.h"
jack1930 2:08ce999855c3 3 #include "string"
jack1930 0:a655fd59ed71 4
jack1930 6:d5d3b2bcb9b8 5
jack1930 0:a655fd59ed71 6 // Library to use https://github.com/ARMmbed/mbed-mqtt
jack1930 0:a655fd59ed71 7 #include <MQTTClientMbedOs.h>
jack1930 5:145eff603968 8
jack1930 5:145eff603968 9
jack1930 2:08ce999855c3 10 using namespace MQTT;
jack1930 0:a655fd59ed71 11
jack1930 0:a655fd59ed71 12 class PubSubClient
jack1930 0:a655fd59ed71 13 {
jack1930 0:a655fd59ed71 14 private:
jack1930 0:a655fd59ed71 15 ESP8266Interface *esp;
jack1930 0:a655fd59ed71 16 SocketAddress deviceIP;
jack1930 0:a655fd59ed71 17 SocketAddress MQTTBroker;
jack1930 0:a655fd59ed71 18 TCPSocket *socket;
jack1930 3:d8582413a5a1 19 MQTTClient *client;
jack1930 0:a655fd59ed71 20 MQTT::Message msg;
jack1930 3:d8582413a5a1 21 MQTTPacket_connectData data;
jack1930 0:a655fd59ed71 22
jack1930 2:08ce999855c3 23 //Subscriptions
jack1930 3:d8582413a5a1 24 /*
jack1930 2:08ce999855c3 25 static int hs_count;
jack1930 2:08ce999855c3 26 static char hs[10][40]; //Topics
jack1930 2:08ce999855c3 27 static Callback< void(string)> cbs[10]; //Callbacks
jack1930 2:08ce999855c3 28 static int topicNr;
jack1930 3:d8582413a5a1 29 */
jack1930 0:a655fd59ed71 30 public:
jack1930 0:a655fd59ed71 31 void init();
jack1930 0:a655fd59ed71 32 PubSubClient(Callback< void()> func);
jack1930 0:a655fd59ed71 33 PubSubClient();
jack1930 0:a655fd59ed71 34 bool connect(char* clientName);
jack1930 0:a655fd59ed71 35 int publish(const char* topic, const char* buf);
jack1930 4:1c121432898d 36 int publish(const char* topic, const char* buf, MQTT::QoS qos);
jack1930 4:1c121432898d 37 int publish(const char* topic, const char* buf, MQTT::QoS qos, bool retain);
jack1930 3:d8582413a5a1 38 int subscribe(const char* topicFilter, MQTT::QoS qos, MQTTClient::messageHandler mh);
jack1930 3:d8582413a5a1 39 //int subscribe(const char* topic,Callback< void(string)> func);
jack1930 3:d8582413a5a1 40 //static void subscribeCallback(MessageData& mymessage);
jack1930 3:d8582413a5a1 41 //static void loop();
jack1930 3:d8582413a5a1 42 int yield(unsigned long timeout_ms = 1000L);
jack1930 3:d8582413a5a1 43 int loop(unsigned long timeout_ms = 1000L);
jack1930 3:d8582413a5a1 44 string gibPayload(MessageData& mymessage);
jack1930 0:a655fd59ed71 45 };