11#ifndef _GVM_UTIL_MQTT_H
12#define _GVM_UTIL_MQTT_H
14#include <MQTTClient.h>
36 const char *,
const char *);
int mqtt_publish_single_message_auth(const char *server_uri_in, const char *username_in, const char *passwd_in, const char *topic, const char *msg)
Send a single message with credentials.
int mqtt_init_auth(const char *server_uri, const char *username, const char *password)
Init MQTT communication.
int mqtt_publish_single_message(const char *server_uri_in, const char *topic, const char *msg)
Send a single message.
gboolean mqtt_is_initialized()
Get the global init status.
int mqtt_retrieve_message(char **topic, int *topic_len, char **payload, int *payload_len, const unsigned int timeout)
wait for a given timeout in ms to retrieve any message of subscribed topics
int mqtt_unsubscribe(const char *topic)
unsubscribe a single topic.
int mqtt_publish(const char *topic, const char *msg)
Publish a message on topic using the global client.
void mqtt_reset()
Destroy MQTTClient handle and free mqtt_t.
int mqtt_init(const char *server_uri)
Init MQTT communication.
int mqtt_subscribe(const char *topic)
subscribes to a single topic.