version 1.1.2.9, 2011/11/28 13:19:38
|
version 1.1.2.11, 2011/12/05 15:30:49
|
Line 9 main()
|
Line 9 main()
|
{ |
{ |
mqtt_msg_t *m; |
mqtt_msg_t *m; |
mqtt_subscr_t s[4]; |
mqtt_subscr_t s[4]; |
|
mqtthdr_connflgs_t flg; |
|
u_short ka; |
int i; |
int i; |
|
char cid[BUFSIZ], user[BUFSIZ], pass[BUFSIZ], topic[BUFSIZ], message[BUFSIZ]; |
|
|
m = mqtt_msgAlloc(0); |
m = mqtt_msgAlloc(0); |
/* conn* */ |
/* conn* */ |
printf("connect=%d/%d\n", m->msg_len, mqtt_msgCONNECT(m, "MRYN", "aaaaa", NULL, "bbb", NULL, 0, 0, 0)); |
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++) |
for (i = 0; i < m->msg_len; i++) |
printf("%d\n", ((u_char*) m->msg_base)[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); |
printf("connack=%d/%d\n", m->msg_len, mqtt_msgCONNACK(m, 1)); |
printf("connack=%d/%d\n", m->msg_len, mqtt_msgCONNACK(m, 1)); |
for (i = 0; i < m->msg_len; i++) |
for (i = 0; i < m->msg_len; i++) |
printf("%d\n", ((u_char*) m->msg_base)[i]); |
printf("%d\n", ((u_char*) m->msg_base)[i]); |
|
printf("read connack=%d\n", mqtt_readCONNACK(m)); |
|
getchar(); |
|
|
/* pub* */ |
/* pub* */ |
printf("publish=%d/%d\n", m->msg_len, mqtt_msgPUBLISH(m, "AAA/bbb/CCC/ddd", 7, 0, 2, 0, "OLE!!!", 7)); |
printf("publish=%d/%d\n", m->msg_len, mqtt_msgPUBLISH(m, "AAA/bbb/CCC/ddd", 7, 0, 2, 0, "OLE!!!", 7)); |