include/mqtt.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

#pragma once

// mosquitto
#include <mosquitto.h>

struct mosquitto *mqtt_connect(const char *clientid, // NOLINT
                               const char *username, // NOLINT
                               const char *password, // NOLINT
                               const char *hostname, // NOLINT
                               int         port,
                               void       *userdata);

void mqtt_run(struct mosquitto    *client,
              const char          *topics[],
              void                 callback(struct mosquitto *, void *, const struct mosquitto_message *),
              const volatile bool *quit);

void mqtt_shutdown(struct mosquitto *client);