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@3:d8582413a5a1, 2021-07-13 (annotated)

Committer:
jack1930
Date:
Tue Jul 13 06:14:41 2021 +0000
Revision:
3:d8582413a5a1
Parent:
2:08ce999855c3
Child:
4:1c121432898d
mit lokalem Broker getestet

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