--- mqtt/example/Attic/cmds.c 2011/11/28 13:19:38 1.1.2.9 +++ mqtt/example/Attic/cmds.c 2011/12/05 14:11:47 1.1.2.10 @@ -9,13 +9,27 @@ main() { mqtt_msg_t *m; mqtt_subscr_t s[4]; + mqtthdr_connflgs_t flg; + u_short ka; int i; + char cid[BUFSIZ], user[BUFSIZ], pass[BUFSIZ], topic[BUFSIZ], message[BUFSIZ]; m = mqtt_msgAlloc(0); /* conn* */ printf("connect=%d/%d\n", m->msg_len, mqtt_msgCONNECT(m, "MRYN", "aaaaa", NULL, "bbb", NULL, 0, 0, 0)); for (i = 0; i < m->msg_len; i++) printf("%d\n", ((u_char*) m->msg_base)[i]); + flg = mqtt_readCONNECT(m, &ka, cid, sizeof cid, user, sizeof user, pass, sizeof pass, + topic, sizeof topic, message, sizeof message); + printf("read connect flags:: clean=%d will=%d qos=%d retain=%d pass=%d user=%d\n", + flg.clean_sess, flg.will_flg, flg.will_qos, flg.will_retain, flg.password, flg.username); + if (flg.reserved) { + printf("Error:: mqtt_readCONNECT() #%d - %s\n", mqtt_GetErrno(), mqtt_GetError()); + return 1; + } + printf("++> KA=%d sec, ConnID=%s User=%s Pass=%s Will_Topic=%s Will_Message=%s\n", ka, + cid, user, pass, topic, message); + getchar(); printf("connack=%d/%d\n", m->msg_len, mqtt_msgCONNACK(m, 1)); for (i = 0; i < m->msg_len; i++) printf("%d\n", ((u_char*) m->msg_base)[i]);