An API for using MQTT over multiple transports
Dependencies: EthernetInterface FP MQTTPacket
Fork of MQTT by
Diff: MQTTEthernet.h
- Revision:
- 29:833386b16f3e
- Child:
- 31:a51dd239b78e
diff -r d13a6c558164 -r 833386b16f3e MQTTEthernet.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/MQTTEthernet.h Tue May 20 15:03:29 2014 +0000 @@ -0,0 +1,49 @@ + +#if !defined(MQTTETHERNET_H) +#define MQTTETHERNET_H + +#include "MQTT_mbed.h" +#include "EthernetInterface.h" + +class MQTTEthernet +{ +public: + MQTTEthernet() + { + eth.init(); // Use DHCP + eth.connect(); + mysock.set_blocking(false, 1000); // 1 second Timeout + } + + int connect(char* hostname, int port) + { + return mysock.connect(hostname, port); + } + + int read(char* buffer, int len, int timeout) + { + mysock.set_blocking(false, timeout); + return mysock.receive(buffer, len); + } + + int write(char* buffer, int len, int timeout) + { + mysock.set_blocking(false, timeout); + return mysock.send(buffer, len); + } + + int disconnect() + { + return mysock.close(); + } + +private: + + EthernetInterface eth; + TCPSocketConnection mysock; + +}; + + + +#endif