version 1.1.2.8, 2011/11/22 14:19:48
|
version 1.1.2.9, 2011/11/28 13:19:38
|
Line 39 main()
|
Line 39 main()
|
|
|
/* sub* */ |
/* sub* */ |
memset(s, 0, sizeof s); |
memset(s, 0, sizeof s); |
s[0].sub_sb.sb.l = 3; | s[0].sub_topic._size = 3; |
s[0].sub_data = "a/b"; | s[0].sub_topic._base = "a/b"; |
s[0].sub_qos = MQTT_QOS_ACK; | s[0].sub_ret = MQTT_QOS_ACK; |
s[1].sub_sb.sb.l = 3; | s[1].sub_topic._size = 3; |
s[1].sub_data = "c/d"; | s[1].sub_topic._base = "c/d"; |
s[1].sub_qos = MQTT_QOS_ONCE; | s[1].sub_ret = MQTT_QOS_ONCE; |
s[2].sub_sb.sb.l = 7; | s[2].sub_topic._size = 7; |
s[2].sub_data = "x/y/z/Q"; | s[2].sub_topic._base = "x/y/z/Q"; |
s[2].sub_qos = MQTT_QOS_EXACTLY; | s[2].sub_ret = MQTT_QOS_EXACTLY; |
printf("subscribe=%d/%d\n", m->msg_len, mqtt_msgSUBSCRIBE(m, s, 10, 0, 0)); |
printf("subscribe=%d/%d\n", m->msg_len, mqtt_msgSUBSCRIBE(m, s, 10, 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]); |