mqtt5properties.h
1.44 KB
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
41
42
#ifndef MQTT5PROPERTIES_H
#define MQTT5PROPERTIES_H
#include <vector>
#include "types.h"
#include "variablebyteint.h"
class Mqtt5PropertyBuilder
{
std::vector<char> genericBytes;
std::vector<char> clientSpecificBytes; // only relevant for publishes
VariableByteInt length;
void writeUint32(Mqtt5Properties prop, const uint32_t x, std::vector<char> &target);
void writeUint16(Mqtt5Properties prop, const uint16_t x);
void writeUint8(Mqtt5Properties prop, const uint8_t x);
void writeStr(Mqtt5Properties prop, const std::string &str);
public:
Mqtt5PropertyBuilder();
size_t getLength();
const VariableByteInt &getVarInt();
const std::vector<char> &getGenericBytes() const;
const std::vector<char> &getclientSpecificBytes() const;
void writeSessionExpiry(uint32_t val);
void writeReceiveMax(uint16_t val);
void writeRetainAvailable(uint8_t val);
void writeMaxPacketSize(uint32_t val);
void writeAssignedClientId(const std::string &clientid);
void writeMaxTopicAliases(uint16_t val);
void writeWildcardSubscriptionAvailable(uint8_t val);
void writeSubscriptionIdentifiersAvailable(uint8_t val);
void writeSharedSubscriptionAvailable(uint8_t val);
void writeContentType(const std::string &format);
void writePayloadFormatIndicator(uint8_t val);
void writeMessageExpiryInterval(uint32_t val);
void writeResponseTopic(const std::string &str);
};
#endif // MQTT5PROPERTIES_H