Diff: MQTTSocket.h

Revision:

45:d8c12dce71b9

Parent:

43:21da1f744243

--- a/MQTTSocket.h	Mon Oct 06 11:41:05 2014 +0000
+++ b/MQTTSocket.h	Mon Jun 29 11:55:39 2015 +0000
@@ -3,7 +3,7 @@
 
 #include "MQTTmbed.h"
 #include "TCPSocketConnection.h"
-
+/*
 class MQTTSocket
 {
 public:    
@@ -35,7 +35,47 @@
     TCPSocketConnection mysock; 
     
 };
+*/
 
+class MQTTSocket
+{
+public: 
+    ~MQTTSocket()
+    {   
+        if(mysock)
+            delete mysock;
+    }  
+      
+    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();
+    }
+
+protected:
+    void createSocket() { mysock = new TCPSocketConnection(); }
+private:
+
+    TCPSocketConnection *mysock; 
+    
+};
 
 
 #endif