MQTT streaming processor for the payload data of a PUBLISH message. More...
Classes | |
struct | MqttPayloadParserState |
Macros | |
#define | MQTT_PAYLOAD_PARSER_START -1 |
#define | MQTT_PAYLOAD_PARSER_END -2 |
#define | MQTT_PAYLOAD_LENGTH 1024 |
Typedefs | |
using | MqttPayloadParser = Delegate< int(MqttPayloadParserState &state, mqtt_message_t *message, const char *buffer, int length)> |
Functions | |
int | defaultPayloadParser (MqttPayloadParserState &state, mqtt_message_t *message, const char *buffer, int length) |
Detailed Description
MQTT streaming processor for the payload data of a PUBLISH message.
Macro Definition Documentation
◆ MQTT_PAYLOAD_LENGTH
#define MQTT_PAYLOAD_LENGTH 1024 |
◆ MQTT_PAYLOAD_PARSER_END
#define MQTT_PAYLOAD_PARSER_END -2 |
◆ MQTT_PAYLOAD_PARSER_START
#define MQTT_PAYLOAD_PARSER_START -1 |
Typedef Documentation
◆ MqttPayloadParser
using MqttPayloadParser = Delegate<int(MqttPayloadParserState& state, mqtt_message_t* message, const char* buffer, int length)> |
A payload parser must return 0 on success
Function Documentation
◆ defaultPayloadParser()
int defaultPayloadParser | ( | MqttPayloadParserState & | state, |
mqtt_message_t * | message, | ||
const char * | buffer, | ||
int | length | ||
) |