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