src/message.h


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

#ifndef MESSAGE_H
#define MESSAGE_H

#include <stdint.h>

#include "queue.h"
#include <bstrlib/bstrlib.h>

enum MqttMessageState
{
    MqttMessageStateQueued,
    MqttMessageStatePublish,
    MqttMessageStateWaitPubAck,
    MqttMessageStateWaitPubRec,
    MqttMessageStateWaitPubComp,
    MqttMessageStateWaitPubRel
};

typedef struct MqttMessage MqttMessage;

struct MqttMessage
{
    int state;
    int qos;
    int retain;
    int dup;
    int padding;
    uint16_t id;
    int64_t timestamp;
    bstring topic;
    bstring payload;
    TAILQ_ENTRY(MqttMessage) chain;
};

typedef struct MqttMessageList MqttMessageList;
TAILQ_HEAD(MqttMessageList, MqttMessage);

void MqttMessageFree(MqttMessage *msg);

#endif