RaspberrPi project source code
Guo Wenxue
2024-12-29 e30a4c8103e221201e5bfc1e3f9b19e7a86f68d4
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
/********************************************************************************
 *      Copyright:  (C) 2021 LingYun IoT System Studio
 *                  All rights reserved.
 *
 *       Filename:  mqtt.h
 *    Description:  This head file is MQTT subscriber and publisher thread code
 *
 *        Version:  1.0.0(20/04/21)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
 *      ChangeLog:  1, Release initial version on "20/04/21 15:46:42"
 *
 ********************************************************************************/
#ifndef  _MQTT_H_
#define  _MQTT_H_
 
 
typedef struct mqtt_ctx_s
{
    char          id[32];       /*  production ID */
 
    /* Broker settings  */
    char          host[128];  /* MQTT broker server name  */
    int           port;       /* MQTT broker listen port  */
    char          uid[64];    /* username */
    char          pwd[64];    /* password */
    int           keepalive;  /* MQTT broker send PING message to subsciber/publisher keepalive timeout<seconds> */
 
    /* Subscriber settings */
    int           sub_enable;    /* Subscriber enable or not  */
    char          subTopic[256]; /* Subscriber topic */
    int           subQos;        /* Subscriber Qos  */
 
    /* Publisher settings */
    int           pub_enable;    /* Publisher enable or not  */
    char          pubTopic[256]; /* Publisher topic */
    int           pubQos;        /* Publisher Qos   */
    int           interval;      /* Publish interval */
} mqtt_ctx_t;
 
 
extern void *mqtt_pub_worker(void *args);
extern void *mqtt_sub_worker(void *args);
 
#endif   /* ----- #ifndef _MQTT_H_  ----- */