--- mqtt/inc/Attic/aitmqtt.h 2011/12/05 17:05:38 1.1.1.1.2.26 +++ mqtt/inc/Attic/aitmqtt.h 2011/12/05 22:17:39 1.1.1.1.2.27 @@ -413,6 +413,42 @@ int mqtt_readPINGREQ(mqtt_msg_t * __restrict buf); */ int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPUBACK() Read PUBACK message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readPUBACK(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPUBREC() Read PUBREC message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readPUBREC(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPUBREL() Read PUBREL message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readPUBREL(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPUBCOMP() Read PUBCOMP message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf); + +/* + * mqtt_readUNSUBACK() Read UNSUBACK message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readUNSUBACK(mqtt_msg_t * __restrict buf); /*** ENGINE FUNCTIONS ***/