MQtt to publish the data
Fork of MQTT by
Diff: MQTTClient.h
- Revision:
- 34:e18a166198df
- Parent:
- 31:a51dd239b78e
- Child:
- 40:9623a2c9c8ac
diff -r a51dd239b78e -r e18a166198df MQTTClient.h --- a/MQTTClient.h Thu May 22 23:58:08 2014 +0000 +++ b/MQTTClient.h Fri Aug 01 12:52:50 2014 +0000 @@ -27,7 +27,7 @@ #if !defined(MQTTCLIENT_H) #define MQTTCLIENT_H -#include "FP.cpp" +#include "FP.h" #include "MQTTPacket.h" #include "stdio.h" @@ -419,7 +419,7 @@ case PUBLISH: MQTTString topicName; Message msg; - if (MQTTDeserialize_publish((int*)&msg.dup, (int*)&msg.qos, (int*)&msg.retained, (int*)&msg.id, &topicName, + if (MQTTDeserialize_publish((unsigned char*)&msg.dup, (int*)&msg.qos, (unsigned char*)&msg.retained, (int*)&msg.id, &topicName, (char**)&msg.payload, (int*)&msg.payloadlen, readbuf, MAX_MQTT_PACKET_SIZE) != 1) goto exit; // if (msg.qos != QOS2) @@ -446,7 +446,8 @@ } break; case PUBREC: - int type, dup, mypacketid; + int type, mypacketid; + unsigned char dup; if (MQTTDeserialize_ack(&type, &dup, &mypacketid, readbuf, MAX_MQTT_PACKET_SIZE) != 1) rc = FAILURE; else if ((len = MQTTSerialize_ack(buf, MAX_MQTT_PACKET_SIZE, PUBREL, 0, mypacketid)) <= 0) @@ -654,7 +655,8 @@ { if (waitfor(PUBACK, timer) == PUBACK) { - int type, dup, mypacketid; + int type, mypacketid; + unsigned char dup; if (MQTTDeserialize_ack(&type, &dup, &mypacketid, readbuf, MAX_MQTT_PACKET_SIZE) != 1) rc = FAILURE; } @@ -665,7 +667,8 @@ { if (waitfor(PUBCOMP, timer) == PUBCOMP) { - int type, dup, mypacketid; + int type, mypacketid; + unsigned char dup; if (MQTTDeserialize_ack(&type, &dup, &mypacketid, readbuf, MAX_MQTT_PACKET_SIZE) != 1) rc = FAILURE; }