Documentation

Documentation

Includes

tuya_cloud_com_defs.h

#include "tuya_cloud_com_defs.h"
#include "tuya_cloud_com_defs.h"

Macros

Marco __LAN_PUB_SUB_MQ_API_H

#define __LAN_PUB_SUB_MQ_API_H


      

Marco LAN_TOPIC_NAME_LEN_MAX

#define LAN_TOPIC_NAME_LEN_MAX 32
/***********************************************************
*************************micro define***********************
***********************************************************/

Functions

Func lan_pub_sub_mq_svc_add

OPERATE_RET lan_pub_sub_mq_svc_add(IN CONST LAN_PUB_SUB_MQ_SVC_PARAM_S *param, OUT LAN_PUB_SUB_MQ_SVC_HANDLE* hdl);


      

Func lan_pub_sub_mq_svc_publish

OPERATE_RET lan_pub_sub_mq_svc_publish(IN LAN_PUB_SUB_MQ_SVC_HANDLE hdl, IN CONST VOID * pub_content);

      

Vars

Consts

Types

Typedefs

Typedef LAN_PUB_SUB_MQ_SVC_HANDLE

typedef VOID* LAN_PUB_SUB_MQ_SVC_HANDLE;


      

Typedef LAN_PUB_SUB_MQ_SVC_FROM_REMOTE_CB

typedef OPERATE_RET (*LAN_PUB_SUB_MQ_SVC_FROM_REMOTE_CB)(IN CONST VOID * pub_content, VOID *cb_param);
//收到其他设备的发布消息,回调

Typedef LAN_PUB_SUB_MQ_SVC_MSG_SERIAL

typedef OPERATE_RET (*LAN_PUB_SUB_MQ_SVC_MSG_SERIAL)(IN CONST VOID * pub_content, OUT CHAR_T **pub_msg);
//消息序列化, msg_json在消息发送后,由模块内部Free释放

Typedef LAN_PUB_SUB_MQ_SVC_MSG_UNSERIAL

typedef OPERATE_RET (*LAN_PUB_SUB_MQ_SVC_MSG_UNSERIAL)(IN CONST CHAR_T *pub_msg, OUT VOID **pub_content);
//消息反序列化, pub_content在回调后,由模块内部调用Free释放

Typedef LAN_PUB_SUB_MQ_SVC_PARAM_S;

typedef struct {
 CHAR_T topic_name[LAN_TOPIC_NAME_LEN_MAX + 1];
 LAN_PUB_SUB_MQ_SVC_FROM_REMOTE_CB func_from_remote; //收到推送后的回调,必须字段
 VOID *cb_param;									//回调的参数
 BOOL_T omit_self;								//自己发布的消息,是否回调
 LAN_PUB_SUB_MQ_SVC_MSG_SERIAL func_serail;		//必须字段
 LAN_PUB_SUB_MQ_SVC_MSG_UNSERIAL func_unserail;	//必须字段
} LAN_PUB_SUB_MQ_SVC_PARAM_S;