multiple.c 629 B

123456789101112131415161718192021222324252627282930313233343536373839
  1. #include <stdlib.h>
  2. #include <stdio.h>
  3. #include "mosquitto.h"
  4. #define COUNT 3
  5. int main(int argc, char *argv[])
  6. {
  7. int rc;
  8. int i;
  9. struct mosquitto_message *msg;
  10. mosquitto_lib_init();
  11. rc = mosquitto_subscribe_simple(
  12. &msg, COUNT, true,
  13. "irc/#", 0,
  14. "test.mosquitto.org", 1883,
  15. NULL, 60, true,
  16. NULL, NULL,
  17. NULL, NULL);
  18. if(rc){
  19. printf("Error: %s\n", mosquitto_strerror(rc));
  20. mosquitto_lib_cleanup();
  21. return rc;
  22. }
  23. for(i=0; i<COUNT; i++){
  24. printf("%s %s\n", msg[i].topic, (char *)msg[i].payload);
  25. mosquitto_message_free_contents(&msg[i]);
  26. }
  27. free(msg);
  28. mosquitto_lib_cleanup();
  29. return 0;
  30. }