Boon Boon / Mbed OS mqtt_thingsboard1

send temp data to thingsboard through mqtt using lpc1768

Dependencies:   C12832 LM75B MQTT

MQTTNetwork.h@0:df50ec82d746, 2018-07-04 (annotated)

Committer:
daklowprofile
Date:
Wed Jul 04 07:27:48 2018 +0000
Revision:
0:df50ec82d746
initial working code

Who changed what in which revision?

UserRevisionLine numberNew contents of line
daklowprofile 0:df50ec82d746 1 #ifndef _MQTTNETWORK_H_
daklowprofile 0:df50ec82d746 2 #define _MQTTNETWORK_H_
daklowprofile 0:df50ec82d746 3
daklowprofile 0:df50ec82d746 4 #include "NetworkInterface.h"
daklowprofile 0:df50ec82d746 5
daklowprofile 0:df50ec82d746 6 class MQTTNetwork {
daklowprofile 0:df50ec82d746 7 public:
daklowprofile 0:df50ec82d746 8 MQTTNetwork(NetworkInterface* aNetwork) : network(aNetwork) {
daklowprofile 0:df50ec82d746 9 socket = new TCPSocket();
daklowprofile 0:df50ec82d746 10 }
daklowprofile 0:df50ec82d746 11
daklowprofile 0:df50ec82d746 12 ~MQTTNetwork() {
daklowprofile 0:df50ec82d746 13 delete socket;
daklowprofile 0:df50ec82d746 14 }
daklowprofile 0:df50ec82d746 15
daklowprofile 0:df50ec82d746 16 int read(unsigned char* buffer, int len, int timeout) {
daklowprofile 0:df50ec82d746 17 return socket->recv(buffer, len);
daklowprofile 0:df50ec82d746 18 }
daklowprofile 0:df50ec82d746 19
daklowprofile 0:df50ec82d746 20 int write(unsigned char* buffer, int len, int timeout) {
daklowprofile 0:df50ec82d746 21 return socket->send(buffer, len);
daklowprofile 0:df50ec82d746 22 }
daklowprofile 0:df50ec82d746 23
daklowprofile 0:df50ec82d746 24 int connect(const char* hostname, int port) {
daklowprofile 0:df50ec82d746 25 socket->open(network);
daklowprofile 0:df50ec82d746 26 return socket->connect(hostname, port);
daklowprofile 0:df50ec82d746 27 }
daklowprofile 0:df50ec82d746 28
daklowprofile 0:df50ec82d746 29 int disconnect() {
daklowprofile 0:df50ec82d746 30 return socket->close();
daklowprofile 0:df50ec82d746 31 }
daklowprofile 0:df50ec82d746 32
daklowprofile 0:df50ec82d746 33 private:
daklowprofile 0:df50ec82d746 34 NetworkInterface* network;
daklowprofile 0:df50ec82d746 35 TCPSocket* socket;
daklowprofile 0:df50ec82d746 36 };
daklowprofile 0:df50ec82d746 37
daklowprofile 0:df50ec82d746 38 #endif // _MQTTNETWORK_H_