--- mqtt/example/Attic/cmds.c 2011/12/06 10:33:37 1.1.2.15 +++ mqtt/example/Attic/cmds.c 2011/12/06 12:36:45 1.1.2.16 @@ -1,4 +1,5 @@ #include +#include #include #include #include @@ -14,6 +15,7 @@ main() int i, len; char cid[BUFSIZ], user[BUFSIZ], pass[BUFSIZ], topic[BUFSIZ], message[BUFSIZ]; struct mqtthdr *hdr; + u_char *qoses; m = mqtt_msgAlloc(0); /* conn* */ @@ -93,9 +95,23 @@ main() printf("suback=%d/%d\n", m->msg_len, mqtt_msgSUBACK(m, s, 10)); for (i = 0; i < m->msg_len; i++) printf("%d\n", ((u_char*) m->msg_base)[i]); + printf("read suback=%d\n", (len = mqtt_readSUBACK(m, &msgID, &qoses))); + for (i = 0; i < len; i++) + printf(" >>> QoS=%d\n", qoses[i]); + free(qoses); printf("unsubscribe=%d/%d\n", m->msg_len, mqtt_msgUNSUBSCRIBE(m, s, 10, 0, 1)); for (i = 0; i < m->msg_len; i++) printf("%d\n", ((u_char*) m->msg_base)[i]); + hdr = mqtt_readUNSUBSCRIBE(m, &msgID, &ss); + if (!hdr) { + printf("Error:: mqtt_readUNSUBSCRIBE() #%d - %s\n", mqtt_GetErrno(), mqtt_GetError()); + return 3; + } + printf("read unsubscribe: dup=%d qos=%d retain=%d\n", hdr->mqtt_msg.dup, hdr->mqtt_msg.qos, hdr->mqtt_msg.retain); + printf("++> MessageID=%d\n", msgID); + for (i = 0; ss[i].sub_topic._base; i++) + printf(" >>> Topic(%d)=%s\n", ss[i].sub_topic._size, ss[i].sub_topic._base); + mqtt_subFree(&ss); printf("unsuback=%d/%d\n", m->msg_len, mqtt_msgUNSUBACK(m, 10)); for (i = 0; i < m->msg_len; i++) printf("%d\n", ((u_char*) m->msg_base)[i]);