Diff: MQTTClient.h

Revision:

0:83c732b10e95

Child:

1:87da395325fc

diff -r 000000000000 -r 83c732b10e95 MQTTClient.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/MQTTClient.h	Mon Sep 15 12:43:54 2014 +0000
@@ -0,0 +1,81 @@
+/*
+  MQTTClient.h - A simple client for MQTT.
+  Nicholas O'Leary
+  http://knolleary.net
+*/
+
+#ifndef MQTTClient_h
+#define MQTTClient_h
+
+#include <mbed.h>
+#include "Client.h"
+//#include "Stream.h"
+
+// MQTT_MAX_PACKET_SIZE : Maximum packet size
+#define MQTT_MAX_PACKET_SIZE 128
+
+// MQTT_KEEPALIVE : keepAlive interval in Seconds
+#define MQTT_KEEPALIVE 15
+
+#define MQTTPROTOCOLVERSION 3
+#define MQTTCONNECT     1 << 4  // Client request to connect to Server
+#define MQTTCONNACK     2 << 4  // Connect Acknowledgment
+#define MQTTPUBLISH     3 << 4  // Publish message
+#define MQTTPUBACK      4 << 4  // Publish Acknowledgment
+#define MQTTPUBREC      5 << 4  // Publish Received (assured delivery part 1)
+#define MQTTPUBREL      6 << 4  // Publish Release (assured delivery part 2)
+#define MQTTPUBCOMP     7 << 4  // Publish Complete (assured delivery part 3)
+#define MQTTSUBSCRIBE   8 << 4  // Client Subscribe request
+#define MQTTSUBACK      9 << 4  // Subscribe Acknowledgment
+#define MQTTUNSUBSCRIBE 10 << 4 // Client Unsubscribe request
+#define MQTTUNSUBACK    11 << 4 // Unsubscribe Acknowledgment
+#define MQTTPINGREQ     12 << 4 // PING Request
+#define MQTTPINGRESP    13 << 4 // PING Response
+#define MQTTDISCONNECT  14 << 4 // Client is Disconnecting
+#define MQTTReserved    15 << 4 // Reserved
+
+#define MQTTQOS0        (0 << 1)
+#define MQTTQOS1        (1 << 1)
+#define MQTTQOS2        (2 << 1)
+
+class MQTTClient
+{
+private:
+    Client* _client;
+    uint8_t buffer[MQTT_MAX_PACKET_SIZE];
+    uint16_t nextMsgId;
+    time_t lastOutActivity;
+    time_t lastInActivity;
+    bool pingOutstanding;
+    void (*onMessage)(char*,uint8_t*,unsigned int);
+    uint16_t readPacket(uint8_t*);
+    uint8_t readByte();
+    bool write(uint8_t header, uint8_t* buf, uint16_t length);
+    uint16_t writeString(char* string, uint8_t* buf, uint16_t pos);
+    IPAddress ip;
+    char* domain;
+    uint16_t port;
+    Stream* stream;
+public:
+    MQTTClient();
+    MQTTClient(IPAddress&, uint16_t, void(*)(char*,uint8_t*,unsigned int),Client& client);
+    MQTTClient(IPAddress&, uint16_t, void(*)(char*,uint8_t*,unsigned int),Client& client, Stream&);
+    MQTTClient(char*, uint16_t, void(*)(char*,uint8_t*,unsigned int),Client& client);
+    MQTTClient(char*, uint16_t, void(*)(char*,uint8_t*,unsigned int),Client& client, Stream&);
+    bool connect(char*);
+    bool connect(char*, char*, char*);
+    bool connect(char*, char*, uint8_t, uint8_t, char*);
+    bool connect(char*, char*, char*, char*, uint8_t, uint8_t, char*);
+    void disconnect();
+    bool publish(char*, char*);
+    bool publish(char*, uint8_t*, unsigned int);
+    bool publish(char*, uint8_t*, unsigned int, bool);
+    bool subscribe(char*);
+    bool subscribe(char*, uint8_t qos);
+    bool unsubscribe(char*);
+    bool loop();
+    bool connected();
+};
+
+
+#endif