Joerg Wende / MQTT

Initial port of the Arduino MQTT Client: http://knolleary.net/arduino-client-for-mqtt/

Dependents:   MQTTTest 2lemetryNXP MyTempuratureMqtt MqttClientEthInt ... more

PubSubClient.h@0:ca855d29545b, 2013-05-26 (annotated)

Committer:
jwende
Date:
Sun May 26 16:52:01 2013 +0000
Revision:
0:ca855d29545b
PubSubClient Library developed for Arduino - http://knolleary.net/arduino-client-for-mqtt/; Initial port to mbed using EthernetInterface

Who changed what in which revision?

UserRevisionLine numberNew contents of line
jwende 0:ca855d29545b 1 /*
jwende 0:ca855d29545b 2 PubSubClient.h - A simple client for MQTT.
jwende 0:ca855d29545b 3 Nicholas O'Leary
jwende 0:ca855d29545b 4 http://knolleary.net
jwende 0:ca855d29545b 5 */
jwende 0:ca855d29545b 6 #include "mbed.h"
jwende 0:ca855d29545b 7 #include "EthernetInterface.h"
jwende 0:ca855d29545b 8 #include "TCPSocketConnection.h"
jwende 0:ca855d29545b 9
jwende 0:ca855d29545b 10 #ifndef PubSubClient_h
jwende 0:ca855d29545b 11 #define PubSubClient_h
jwende 0:ca855d29545b 12
jwende 0:ca855d29545b 13
jwende 0:ca855d29545b 14
jwende 0:ca855d29545b 15 // MQTT_MAX_PACKET_SIZE : Maximum packet size
jwende 0:ca855d29545b 16 #define MQTT_MAX_PACKET_SIZE 128
jwende 0:ca855d29545b 17
jwende 0:ca855d29545b 18 // MQTT_KEEPALIVE : keepAlive interval in Seconds
jwende 0:ca855d29545b 19 #define MQTT_KEEPALIVE 15
jwende 0:ca855d29545b 20
jwende 0:ca855d29545b 21 #define MQTTPROTOCOLVERSION 3
jwende 0:ca855d29545b 22 #define MQTTCONNECT 1 << 4 // Client request to connect to Server
jwende 0:ca855d29545b 23 #define MQTTCONNACK 2 << 4 // Connect Acknowledgment
jwende 0:ca855d29545b 24 #define MQTTPUBLISH 3 << 4 // Publish message
jwende 0:ca855d29545b 25 #define MQTTPUBACK 4 << 4 // Publish Acknowledgment
jwende 0:ca855d29545b 26 #define MQTTPUBREC 5 << 4 // Publish Received (assured delivery part 1)
jwende 0:ca855d29545b 27 #define MQTTPUBREL 6 << 4 // Publish Release (assured delivery part 2)
jwende 0:ca855d29545b 28 #define MQTTPUBCOMP 7 << 4 // Publish Complete (assured delivery part 3)
jwende 0:ca855d29545b 29 #define MQTTSUBSCRIBE 8 << 4 // Client Subscribe request
jwende 0:ca855d29545b 30 #define MQTTSUBACK 9 << 4 // Subscribe Acknowledgment
jwende 0:ca855d29545b 31 #define MQTTUNSUBSCRIBE 10 << 4 // Client Unsubscribe request
jwende 0:ca855d29545b 32 #define MQTTUNSUBACK 11 << 4 // Unsubscribe Acknowledgment
jwende 0:ca855d29545b 33 #define MQTTPINGREQ 12 << 4 // PING Request
jwende 0:ca855d29545b 34 #define MQTTPINGRESP 13 << 4 // PING Response
jwende 0:ca855d29545b 35 #define MQTTDISCONNECT 14 << 4 // Client is Disconnecting
jwende 0:ca855d29545b 36 #define MQTTReserved 15 << 4 // Reserved
jwende 0:ca855d29545b 37
jwende 0:ca855d29545b 38 #define MQTTQOS0 (0 << 1)
jwende 0:ca855d29545b 39 #define MQTTQOS1 (1 << 1)
jwende 0:ca855d29545b 40 #define MQTTQOS2 (2 << 1)
jwende 0:ca855d29545b 41
jwende 0:ca855d29545b 42 class PubSubClient {
jwende 0:ca855d29545b 43 private:
jwende 0:ca855d29545b 44 TCPSocketConnection _client;
jwende 0:ca855d29545b 45 char buffer[MQTT_MAX_PACKET_SIZE];
jwende 0:ca855d29545b 46 int nextMsgId;
jwende 0:ca855d29545b 47 unsigned long lastOutActivity;
jwende 0:ca855d29545b 48 unsigned long lastInActivity;
jwende 0:ca855d29545b 49 bool pingOutstanding;
jwende 0:ca855d29545b 50 void (*callback)(char*,char*,unsigned int);
jwende 0:ca855d29545b 51 int readPacket(int);
jwende 0:ca855d29545b 52 char readByte();
jwende 0:ca855d29545b 53 bool write(short header, char* buf, int length);
jwende 0:ca855d29545b 54 int writeString(char* string, char* buf, int pos);
jwende 0:ca855d29545b 55 char* ip;
jwende 0:ca855d29545b 56 int port;
jwende 0:ca855d29545b 57 public:
jwende 0:ca855d29545b 58 PubSubClient();
jwende 0:ca855d29545b 59 PubSubClient(char*, int, void(*)(char*,char*,unsigned int));
jwende 0:ca855d29545b 60 bool connect(char *);
jwende 0:ca855d29545b 61 bool connect(char *, char *, char *);
jwende 0:ca855d29545b 62 bool connect(char *, char *, short, short, char *);
jwende 0:ca855d29545b 63 bool connect(char *, char *, char *, char *, short, short, char*);
jwende 0:ca855d29545b 64 void disconnect();
jwende 0:ca855d29545b 65 bool publish(char *, char *);
jwende 0:ca855d29545b 66 bool publish(char *, char *, unsigned int);
jwende 0:ca855d29545b 67 bool publish(char *, char *, unsigned int, bool);
jwende 0:ca855d29545b 68 // bool publish_P(char *, short PROGMEM *, unsigned int, bool);
jwende 0:ca855d29545b 69 bool subscribe(char *);
jwende 0:ca855d29545b 70 bool unsubscribe(char *);
jwende 0:ca855d29545b 71 bool loop();
jwende 0:ca855d29545b 72 bool connected();
jwende 0:ca855d29545b 73 };
jwende 0:ca855d29545b 74
jwende 0:ca855d29545b 75
jwende 0:ca855d29545b 76 #endif