--- mqtt/inc/Attic/aitmqtt.h 2011/11/21 14:51:23 1.1.1.1.2.9 +++ mqtt/inc/Attic/aitmqtt.h 2011/11/21 15:27:26 1.1.1.1.2.11 @@ -218,10 +218,14 @@ int mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, unsig * @msgID = MessageID >0, if QOS != MQTT_QOS_ONCE * @Dup = Duplicate message * @QOS = QoS + * @Retain = Retain message + * @pData = Publish data into topic + * @datlen = Publish data length * return: -1 error or >-1 message size for send */ -int mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const char *csTopic, - unsigned short msgID, unsigned char Dup, unsigned char QOS); +int mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const char *csTopic, unsigned short msgID, + unsigned char Dup, unsigned char QOS, unsigned char Retain, + const void *pData, unsigned short datlen); /* * mqtt_msgPUBACK() Create PUBACK message *