111 void my_publish_callback(struct mosquitto *mosq, void *obj, int mid) |
111 void my_publish_callback(struct mosquitto *mosq, void *obj, int mid) |
112 { |
112 { |
113 fprintf(stdout, (char *)"my_publish_callback mid=%d\n", mid); |
113 fprintf(stdout, (char *)"my_publish_callback mid=%d\n", mid); |
114 |
114 |
115 last_mid_sent = mid; |
115 last_mid_sent = mid; |
116 // if(mode == MSGMODE_STDIN_LINE){ |
|
117 // if(mid == last_mid){ |
|
118 // mosquitto_disconnect(mosq); |
|
119 // disconnect_sent = true; |
|
120 // } |
|
121 // }else if(disconnect_sent == false){ |
|
122 // mosquitto_disconnect(mosq); |
|
123 // disconnect_sent = true; |
|
124 // } |
|
125 } |
116 } |
126 |
117 |
127 |
118 |
128 |
119 |
129 void my_log_callback(struct mosquitto *mosq, void *obj, int level, const char *str) |
120 void my_log_callback(struct mosquitto *mosq, void *obj, int level, const char *str) |
130 { |
121 { |
131 printf("%s\n", str); |
122 printf("log: %s\n", str); |
132 } |
123 } |
133 |
124 |
134 |
125 |
135 |
126 |
136 int main(int argc, char *argv[]) |
127 int main(int argc, char *argv[]) |