Provides MQTT payload parser

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
	)