|
|
add keep alive timeout to msgCONNECT api
1: #ifndef __MQTT_H
2: #define __MQTT_H
3:
4:
5: struct tagArgs {
6: io_sockaddr_t addr;
7: u_short ka;
8: mqtt_msg_t *msg;
9:
10: ait_val_t ConnID;
11: ait_val_t User;
12: ait_val_t Pass;
13:
14: struct {
15: ait_val_t Topic;
16: ait_val_t Msg;
17: } Will;
18:
19: u_char Dup;
20: u_char Retain;
21: u_char QoS;
22: u_char notClear;
23:
24: struct {
25: u_char isFile;
26: ait_val_t Value;
27: };
28:
29: ait_val_t Publish;
30:
31: array_t *Subscribes;
32:
33: void (*free)(struct tagArgs*);
34: };
35:
36: extern struct tagArgs *args;
37:
38:
39: #endif