1 #include <stdlib.h>
2 #include <stdio.h>
3 #include "mosquitto.h"
4
on_message(struct mosquitto * mosq,void * userdata,const struct mosquitto_message * msg)5 int on_message(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *msg)
6 {
7 printf("%s %s (%d)\n", msg->topic, (const char *)msg->payload, msg->payloadlen);
8 return 0;
9 }
10
11
main(int argc,char * argv[])12 int main(int argc, char *argv[])
13 {
14 int rc;
15
16 mosquitto_lib_init();
17
18 rc = mosquitto_subscribe_callback(
19 on_message, NULL,
20 "irc/#", 0,
21 "test.mosquitto.org", 1883,
22 NULL, 60, true,
23 NULL, NULL,
24 NULL, NULL);
25
26 if(rc){
27 printf("Error: %s\n", mosquitto_strerror(rc));
28 }
29
30 mosquitto_lib_cleanup();
31
32 return rc;
33 }
34
35