dtu_lan_gateway/app/System/includes/sys_mqtt.h

#ifndef SYS_MQTT_H
#define SYS_MQTT_H

#include "ucos_ii.h"
#include "gateway_message.h"
#include "json_queue.h"

#define  MBOX_NETWORK_ERROR     0xf0000000

#define  MBOX_MQTT_QOS1PUBACK   0x10000001
#define  MBOX_MQTT_QOS2PUBREC   0x10000002
#define  MBOX_MQTT_QOS2PUBCOMP  0x10000003

#define  MBOX_USER_PUBLISHQOS0  0x20000001
#define  MBOX_USER_PUBLISHQOS1  0x20000002
#define  MBOX_USER_PUBLISHQOS2  0x20000003

#define  MQTT_PRINTF  printf


//#define  MQTT_SERVER_ADDR  "192.168.0.116"
//#define  MQTT_SERVER_ADDR  "192.168.0.183"
//#define  MQTT_SERVER_ADDR  "36.134.23.11"
//#define  MQTT_SERVER_PORT  1883

#define  CLIENT_ID     "stm32f207DTtest0002"       
//#define  USER_NAME     "emqxxx"     
//#define  PASSWORD      "123456" 
//#define  USER_NAME     NULL  
//#define  PASSWORD      NULL
#define  KEEPLIVE_TIME   120
#define  MQTT_VERSION    4

//#define  TOPICSTM32    "test/stm32"
//#define  TOPICPC       "test/pc"
//#define  TOPICTEST     "/device/cxw0817111032"


extern int mqtt_connectFlag;
extern OS_EVENT *mqtt_sendMseeageMbox;
extern OS_EVENT *mqtt_recvMseeageMbox;
extern OS_EVENT *JsonQ;
void mqtt_threadCreate(void);


#define jsonMaxSize 2 * 1024
extern char pubJsonString[jsonMaxSize];
extern char pubJsonStringCopy[jsonMaxSize];
#endif