Initial port of the Arduino MQTT Client: http://knolleary.net/arduino-client-for-mqtt/ Updated with larger timeout and buffer sizes
Dependents: mbed_mqtt_endpoint_ublox_ethernet mbed_mqtt_endpoint_ublox_cellular mbed_mqtt_endpoint_nxp
Fork of MQTT by
Diff: PubSubClient.h
- Revision:
- 0:ca855d29545b
- Child:
- 1:0f810fceda0a
diff -r 000000000000 -r ca855d29545b PubSubClient.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/PubSubClient.h Sun May 26 16:52:01 2013 +0000 @@ -0,0 +1,76 @@ +/* +PubSubClient.h - A simple client for MQTT. +Nicholas O'Leary +http://knolleary.net +*/ +#include "mbed.h" +#include "EthernetInterface.h" +#include "TCPSocketConnection.h" + +#ifndef PubSubClient_h +#define PubSubClient_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 PubSubClient { +private: + TCPSocketConnection _client; + char buffer[MQTT_MAX_PACKET_SIZE]; + int nextMsgId; + unsigned long lastOutActivity; + unsigned long lastInActivity; + bool pingOutstanding; + void (*callback)(char*,char*,unsigned int); + int readPacket(int); + char readByte(); + bool write(short header, char* buf, int length); + int writeString(char* string, char* buf, int pos); + char* ip; + int port; +public: + PubSubClient(); + PubSubClient(char*, int, void(*)(char*,char*,unsigned int)); + bool connect(char *); + bool connect(char *, char *, char *); + bool connect(char *, char *, short, short, char *); + bool connect(char *, char *, char *, char *, short, short, char*); + void disconnect(); + bool publish(char *, char *); + bool publish(char *, char *, unsigned int); + bool publish(char *, char *, unsigned int, bool); +// bool publish_P(char *, short PROGMEM *, unsigned int, bool); + bool subscribe(char *); + bool unsubscribe(char *); + bool loop(); + bool connected(); +}; + + +#endif \ No newline at end of file