An API for using MQTT over multiple transports
Dependents: Water_Monitor_clone_v1 Cloud_IBM_MbedOS ble-star-mbed
Fork of MQTT by
MQTTSocket.h
- Committer:
- Jan Jongboom
- Date:
- 2017-09-07
- Revision:
- 49:08571008b958
- Parent:
- 43:21da1f744243
- Child:
- 54:ff9e5c4b52d0
File content as of revision 49:08571008b958:
#if !defined(MQTTSOCKET_H)
#define MQTTSOCKET_H
#include "MQTTmbed.h"
#include "TCPSocketConnection.h"
class MQTTSocket
{
public:
int connect(char* hostname, int port, int timeout=1000)
{
mysock.set_blocking(false, timeout); // 1 second Timeout
return mysock.connect(hostname, port);
}
int read(unsigned char* buffer, int len, int timeout)
{
mysock.set_blocking(false, timeout);
return mysock.receive((char*)buffer, len);
}
int write(unsigned char* buffer, int len, int timeout)
{
mysock.set_blocking(false, timeout);
return mysock.send((char*)buffer, len);
}
int disconnect()
{
return mysock.close();
}
bool is_connected()
{
return mysock.is_connected();
}
private:
TCPSocketConnection mysock;
};
#endif
