ReactOS 0.4.16-dev-297-gc569aee
|
Modules | |
Options | |
Classes | |
struct | mqtt_connect_client_info_t |
Macros | |
#define | MQTT_PORT LWIP_IANA_PORT_MQTT |
#define | MQTT_TLS_PORT LWIP_IANA_PORT_SECURE_MQTT |
#define | mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1) |
#define | mqtt_unsubscribe(client, topic, cb, arg) mqtt_sub_unsub(client, topic, 0, cb, arg, 0) |
Typedefs | |
typedef void(* | mqtt_connection_cb_t) (mqtt_client_t *client, void *arg, mqtt_connection_status_t status) |
typedef void(* | mqtt_incoming_data_cb_t) (void *arg, const u8_t *data, u16_t len, u8_t flags) |
typedef void(* | mqtt_incoming_publish_cb_t) (void *arg, const char *topic, u32_t tot_len) |
typedef void(* | mqtt_request_cb_t) (void *arg, err_t err) |
Enumerations | |
enum | mqtt_connection_status_t { MQTT_CONNECT_ACCEPTED = 0 , MQTT_CONNECT_REFUSED_PROTOCOL_VERSION = 1 , MQTT_CONNECT_REFUSED_IDENTIFIER = 2 , MQTT_CONNECT_REFUSED_SERVER = 3 , MQTT_CONNECT_REFUSED_USERNAME_PASS = 4 , MQTT_CONNECT_REFUSED_NOT_AUTHORIZED_ = 5 , MQTT_CONNECT_DISCONNECTED = 256 , MQTT_CONNECT_TIMEOUT = 257 } |
enum | { MQTT_DATA_FLAG_LAST = 1 } |
#define MQTT_PORT LWIP_IANA_PORT_MQTT |
#define MQTT_TLS_PORT LWIP_IANA_PORT_SECURE_MQTT |
typedef void(* mqtt_connection_cb_t) (mqtt_client_t *client, void *arg, mqtt_connection_status_t status) |
Function prototype for mqtt connection status callback. Called when client has connected to the server after initiating a mqtt connection attempt by calling mqtt_client_connect() or when connection is closed by server or an error
client | MQTT client itself |
arg | Additional argument to pass to the callback function |
status | Connect result code or disconnection notification |
Function prototype for MQTT incoming publish data callback function. Called when data arrives to a subscribed topic
arg | Additional argument to pass to the callback function |
data | User data, pointed object, data may not be referenced after callback return, NULL is passed when all publish data are delivered |
len | Length of publish data fragment |
flags | MQTT_DATA_FLAG_LAST set when this call contains the last part of data from publish message |
Function prototype for MQTT incoming publish function. Called when an incoming publish arrives to a subscribed topic
arg | Additional argument to pass to the callback function |
topic | Zero terminated Topic text string, topic may not be referenced after callback return |
tot_len | Total length of publish data, if set to 0 (no publish payload) data callback will not be invoked |
Function prototype for mqtt request callback. Called when a subscribe, unsubscribe or publish request has completed
arg | Pointer to user data supplied when invoking request |
err | ERR_OK on success ERR_TIMEOUT if no response was received within timeout, ERR_ABRT if (un)subscribe was denied |
anonymous enum |
Data callback flags
Enumerator | |
---|---|
MQTT_DATA_FLAG_LAST | Flag set when last fragment of data arrives in data callback |
Connection status codes
Definition at line 95 of file mqtt.h.