--- mqtt/example/Attic/cmds.c 2011/12/06 09:04:55 1.1.2.14 +++ mqtt/example/Attic/cmds.c 2011/12/06 10:33:37 1.1.2.15 @@ -8,7 +8,7 @@ int main() { mqtt_msg_t *m; - mqtt_subscr_t s[4]; + mqtt_subscr_t s[4], *ss; mqtthdr_connflgs_t flg; u_short ka, msgID; int i, len; @@ -80,6 +80,16 @@ main() printf("subscribe=%d/%d\n", m->msg_len, mqtt_msgSUBSCRIBE(m, s, 10, 0, 0)); for (i = 0; i < m->msg_len; i++) printf("%d\n", ((u_char*) m->msg_base)[i]); + hdr = mqtt_readSUBSCRIBE(m, &msgID, &ss); + if (!hdr) { + printf("Error:: mqtt_readSUBSCRIBE() #%d - %s\n", mqtt_GetErrno(), mqtt_GetError()); + return 3; + } + printf("read subscribe: 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(" >>> QoS=%d Topic(%d)=%s\n", ss[i].sub_ret, ss[i].sub_topic._size, ss[i].sub_topic._base); + mqtt_subFree(&ss); 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]);