aiot_message_api.h

浏览该文件的文档.

#ifndef _AIOT_MESSAGE_API_H_
#define _AIOT_MESSAGE_API_H_

#if defined(__cplusplus)
extern "C" {
#endif

#include <stdint.h>


typedef struct {
 char *topic; /* 消息的话题，类似于命令字 */
 uint8_t *payload; /* 消息的载体 */
 uint32_t payload_lenth; /* 消息的载体长度 */
 char qos; /* 消息的质量等级，0：至多一次到达 1:至少一次到达 */
 uint32_t id; /* Alink协议的消息id */

 /* 接收消息：rrpc报文:云端对设备的同步调用，需要保存上下文信息以便消息返回 */
 char *rrpc_id;
 int32_t rrpc_cid;
} aiot_msg_t;

aiot_msg_t* aiot_msg_create_raw(char *topic, uint8_t *payload, uint32_t payload_lenth);

aiot_msg_t* aiot_msg_create_user_define(char *productKey, char *deviceName, char *sub_topic, uint8_t *payload, uint32_t payload_lenth);

aiot_msg_t* aiot_msg_create_rrpc_reply(const aiot_msg_t *message, uint8_t *payload, uint32_t payload_lenth);

aiot_msg_t* aiot_msg_clone(aiot_msg_t* message);

int32_t aiot_msg_delete(aiot_msg_t* message);

int32_t aiot_msg_set_qos(aiot_msg_t* message, uint8_t qos);


#if defined(__cplusplus)
}
#endif

#endif