|
|
|
@ -421,7 +421,6 @@ void my_log_callback(struct mosquitto *mosq, void *userdata, int level, const ch
|
|
|
|
|
|
|
|
|
|
int main(int argc, char *argv[])
|
|
|
|
|
{
|
|
|
|
|
char id[30];
|
|
|
|
|
int i;
|
|
|
|
|
char *host = "localhost";
|
|
|
|
|
int port = 1883;
|
|
|
|
@ -430,13 +429,12 @@ int main(int argc, char *argv[])
|
|
|
|
|
struct mosquitto *mosq = NULL;
|
|
|
|
|
|
|
|
|
|
mosquitto_lib_init();
|
|
|
|
|
mosq = mosquitto_new(id, clean_session, NULL);
|
|
|
|
|
mosq = mosquitto_new(NULL, clean_session, NULL);
|
|
|
|
|
if(!mosq){
|
|
|
|
|
fprintf(stderr, "Error: Out of memory.\n");
|
|
|
|
|
return 1;
|
|
|
|
|
}
|
|
|
|
|
mosquitto_log_callback_set(mosq, my_log_callback);
|
|
|
|
|
|
|
|
|
|
mosquitto_connect_callback_set(mosq, my_connect_callback);
|
|
|
|
|
mosquitto_message_callback_set(mosq, my_message_callback);
|
|
|
|
|
mosquitto_subscribe_callback_set(mosq, my_subscribe_callback);
|
|
|
|
@ -446,7 +444,7 @@ int main(int argc, char *argv[])
|
|
|
|
|
return 1;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
while(!mosquitto_loop(mosq, -1)){
|
|
|
|
|
while(!mosquitto_loop(mosq, -1, 1)){
|
|
|
|
|
}
|
|
|
|
|
mosquitto_destroy(mosq);
|
|
|
|
|
mosquitto_lib_cleanup();
|
|
|
|
|