Diff: MQTT/MQTTPacket/samples/publish-subscribe.txt

Revision:

9:58eb378727d9

Parent:

8:80d49dd91542

Child:

10:0b5e0dfee08e

--- a/MQTT/MQTTPacket/samples/publish-subscribe.txt	Wed Oct 01 13:27:35 2014 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,115 +0,0 @@
-#include "MQTTPacket.h"
-
-#include <errno.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include "EthernetInterface.h"
-
-
-TCPSocketConnection mysock; 
-
-int getdata(char* buf, int count)
-{
-    return mysock.receive(buf, (size_t)count);
-}
-
-int toStop = 0;
-
-
-int main()
-{
-    MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
-    int rc = 0;
-    char buf[200];
-    int buflen = sizeof(buf);
-    int msgid = 1;
-    MQTTString topicString = MQTTString_initializer;
-    int req_qos = 0;
-    char* payload = "mypayload";
-    int payloadlen = strlen(payload);
-    int len = 0;
-    EthernetInterface eth;
-    
-    eth.init(); //Use DHCP
-    eth.connect();
-
-    rc = mysock.connect("m2m.eclipse.org", 1883);
-
-    data.clientID.cstring = "SendReceive mbed MQTT ";
-    data.keepAliveInterval = 20;
-    data.cleansession = 1;
-
-    mysock.set_blocking(true, 1000);  /* 1 second Timeout */
-
-    len = MQTTSerialize_connect(buf, buflen, &data);
-    rc = mysock.send(buf, len);
-
-    /* wait for connack */
-    if (MQTTPacket_read(buf, buflen, getdata) == CONNACK)
-    {
-        int connack_rc;
-
-        if (MQTTDeserialize_connack(&connack_rc, buf, buflen) != 1 || connack_rc != 0)
-        {
-            printf("Unable to connect, return code %d\n", connack_rc);
-            goto exit;
-        }
-    }
-    else
-        goto exit;
-
-    /* subscribe */
-    topicString.cstring = "substopic";
-    len = MQTTSerialize_subscribe(buf, buflen, 0, msgid, 1, &topicString, &req_qos);
-
-    rc = mysock.send(buf, len);
-    if (MQTTPacket_read(buf, buflen, getdata) == SUBACK)    /* wait for suback */
-    {
-        int submsgid;
-        int subcount;
-        int granted_qos;
-
-        rc = MQTTDeserialize_suback(&submsgid, 1, &subcount, &granted_qos, buf, buflen);
-        if (granted_qos != 0)
-        {
-            printf("granted qos != 0, %d\n", granted_qos);
-            goto exit;
-        }
-    }
-    else
-        goto exit;
-
-    topicString.cstring = "pubtopic";
-    while (!toStop)
-    {
-        if (MQTTPacket_read(buf, buflen, getdata) == PUBLISH)
-        {
-            int dup;
-            int qos;
-            int retained;
-            int msgid;
-            int payloadlen_in;
-            char* payload_in;
-            int rc;
-            MQTTString receivedTopic;
-
-            rc = MQTTDeserialize_publish(&dup, &qos, &retained, &msgid, &receivedTopic,
-                    &payload_in, &payloadlen_in, buf, buflen);
-            printf("message arrived %.*s\n", payloadlen_in, payload_in);
-        }
-
-        printf("publishing reading\n");
-        len = MQTTSerialize_publish(buf, buflen, 0, 0, 0, 0, topicString, payload, payloadlen);
-        rc = mysock.send(buf, len);
-    }
-
-    printf("disconnecting\n");
-    len = MQTTSerialize_disconnect(buf, buflen);
-    rc = mysock.send(buf, len);
-
-exit:    
-    eth.disconnect();
-
-    return 0;
-}