ReactOS 0.4.16-dev-297-gc569aee
mqtt.h
Go to the documentation of this file.
1
6/*
7 * Copyright (c) 2016 Erik Andersson
8 * All rights reserved.
9 *
10 * Redistribution and use in source and binary forms, with or without modification,
11 * are permitted provided that the following conditions are met:
12 *
13 * 1. Redistributions of source code must retain the above copyright notice,
14 * this list of conditions and the following disclaimer.
15 * 2. Redistributions in binary form must reproduce the above copyright notice,
16 * this list of conditions and the following disclaimer in the documentation
17 * and/or other materials provided with the distribution.
18 * 3. The name of the author may not be used to endorse or promote products
19 * derived from this software without specific prior written permission.
20 *
21 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
22 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
23 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT
24 * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
25 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT
26 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
27 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
28 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
29 * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY
30 * OF SUCH DAMAGE.
31 *
32 * This file is part of the lwIP TCP/IP stack.
33 *
34 * Author: Erik Andersson
35 *
36 */
37#ifndef LWIP_HDR_APPS_MQTT_CLIENT_H
38#define LWIP_HDR_APPS_MQTT_CLIENT_H
39
40#include "lwip/apps/mqtt_opts.h"
41#include "lwip/err.h"
42#include "lwip/ip_addr.h"
43#include "lwip/prot/iana.h"
44
45#ifdef __cplusplus
46extern "C" {
47#endif
48
50
51#if LWIP_ALTCP && LWIP_ALTCP_TLS
52struct altcp_tls_config;
53#endif
54
57#define MQTT_PORT LWIP_IANA_PORT_MQTT
60#define MQTT_TLS_PORT LWIP_IANA_PORT_SECURE_MQTT
61
62/*---------------------------------------------------------------------------------------------- */
63/* Connection with server */
64
70 const char *client_id;
72 const char* client_user;
74 const char* client_pass;
79 const char* will_topic;
81 const char* will_msg;
86#if LWIP_ALTCP && LWIP_ALTCP_TLS
88 struct altcp_tls_config *tls_config;
89#endif
90};
91
95typedef enum
96{
114
127
128
132enum {
136
150
151
161typedef void (*mqtt_incoming_publish_cb_t)(void *arg, const char *topic, u32_t tot_len);
162
163
173typedef void (*mqtt_request_cb_t)(void *arg, err_t err);
174
175
178
180
183
185
187 mqtt_incoming_data_cb_t data_cb, void *arg);
188
190
193#define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1)
196#define mqtt_unsubscribe(client, topic, cb, arg) mqtt_sub_unsub(client, topic, 0, cb, arg, 0)
197
198err_t mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain,
199 mqtt_request_cb_t cb, void *arg);
200
201#ifdef __cplusplus
202}
203#endif
204
205#endif /* LWIP_HDR_APPS_MQTT_CLIENT_H */
USHORT port
Definition: uri.c:228
GLint GLenum GLsizei GLsizei GLsizei GLint GLsizei const GLvoid * data
Definition: gl.h:1950
GLbitfield flags
Definition: glext.h:7161
GLenum GLsizei len
Definition: glext.h:6722
uint32_t u32_t
Definition: arch.h:129
uint8_t u8_t
Definition: arch.h:125
uint16_t u16_t
Definition: arch.h:127
s8_t err_t
Definition: err.h:96
void(* mqtt_incoming_publish_cb_t)(void *arg, const char *topic, u32_t tot_len)
Definition: mqtt.h:161
void(* mqtt_connection_cb_t)(mqtt_client_t *client, void *arg, mqtt_connection_status_t status)
Definition: mqtt.h:126
mqtt_connection_status_t
Definition: mqtt.h:96
void(* mqtt_request_cb_t)(void *arg, err_t err)
Definition: mqtt.h:173
void(* mqtt_incoming_data_cb_t)(void *arg, const u8_t *data, u16_t len, u8_t flags)
Definition: mqtt.h:149
@ MQTT_CONNECT_ACCEPTED
Definition: mqtt.h:98
@ MQTT_CONNECT_REFUSED_IDENTIFIER
Definition: mqtt.h:102
@ MQTT_CONNECT_REFUSED_USERNAME_PASS
Definition: mqtt.h:106
@ MQTT_CONNECT_DISCONNECTED
Definition: mqtt.h:110
@ MQTT_CONNECT_REFUSED_PROTOCOL_VERSION
Definition: mqtt.h:100
@ MQTT_CONNECT_TIMEOUT
Definition: mqtt.h:112
@ MQTT_CONNECT_REFUSED_SERVER
Definition: mqtt.h:104
@ MQTT_CONNECT_REFUSED_NOT_AUTHORIZED_
Definition: mqtt.h:108
@ MQTT_DATA_FLAG_LAST
Definition: mqtt.h:134
ip6_addr_t ip_addr_t
Definition: ip_addr.h:344
static HMODULE MODULEINFO DWORD cb
Definition: module.c:33
void mqtt_disconnect(mqtt_client_t *client)
u8_t mqtt_client_is_connected(mqtt_client_t *client)
void mqtt_client_free(mqtt_client_t *client)
err_t mqtt_client_connect(mqtt_client_t *client, const ip_addr_t *ipaddr, u16_t port, mqtt_connection_cb_t cb, void *arg, const struct mqtt_connect_client_info_t *client_info)
mqtt_client_t * mqtt_client_new(void)
err_t mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain, mqtt_request_cb_t cb, void *arg)
err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub)
void mqtt_set_inpub_callback(mqtt_client_t *client, mqtt_incoming_publish_cb_t pub_cb, mqtt_incoming_data_cb_t data_cb, void *arg)
static const char topic[]
Definition: propsys.c:44
#define err(...)
static FILE * client
Definition: client.c:41
const char * will_topic
Definition: mqtt.h:79
const char * client_pass
Definition: mqtt.h:74
const char * will_msg
Definition: mqtt.h:81
const char * client_id
Definition: mqtt.h:70
const char * client_user
Definition: mqtt.h:72
Definition: ps.c:97
void * arg
Definition: msvc.h:10