03-publish-b2c-qos2-unexpected-pubcomp.c 693 B

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. #include <stdbool.h>
  2. #include <stdio.h>
  3. #include <stdlib.h>
  4. #include <string.h>
  5. #include <mosquitto.h>
  6. static int run = -1;
  7. void on_connect(struct mosquitto *mosq, void *obj, int rc)
  8. {
  9. if(rc){
  10. printf("Connect error: %d\n", rc);
  11. exit(1);
  12. }
  13. }
  14. int main(int argc, char *argv[])
  15. {
  16. int rc;
  17. struct mosquitto *mosq;
  18. int port = atoi(argv[1]);
  19. mosquitto_lib_init();
  20. mosq = mosquitto_new("publish-qos2-test", true, &run);
  21. if(mosq == NULL){
  22. return 1;
  23. }
  24. mosquitto_connect_callback_set(mosq, on_connect);
  25. rc = mosquitto_connect(mosq, "localhost", port, 5);
  26. while(run == -1){
  27. rc = mosquitto_loop(mosq, 300, 1);
  28. if(rc){
  29. exit(0);
  30. }
  31. }
  32. mosquitto_lib_cleanup();
  33. return 0;
  34. }