include/mqtt.h


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

#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        callback(struct mosquitto *, void *, const struct mosquitto_message *),
                               void       *userdata);

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

void mqtt_shutdown(struct mosquitto *client);