--- mqtt/inc/Attic/aitmqtt.h	2011/11/21 16:28:05	1.1.1.1.2.12
+++ mqtt/inc/Attic/aitmqtt.h	2011/11/22 12:02:17	1.1.1.1.2.14
@@ -194,9 +194,10 @@ inline mqtt_subscr_t *mqtt_str2sub(const char **csStr,
  * mqtt_freeSub() Free array from subscribe variables
  *
  * @subs = Subscribe variables
+ * @freeall = if !=0 free and subs pointer
  * return: none
  */
-inline void mqtt_freeSub(mqtt_subscr_t ** __restrict subs);
+inline void mqtt_freeSub(mqtt_subscr_t ** __restrict subs, int freeeall);
 
 /*
  * mqtt_msgCONNECT() Create CONNECT message
@@ -224,6 +225,7 @@ int mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const
  * return: -1 error or >-1 message size for send
  */
 int mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, unsigned char retcode);
+
 /*
  * mqtt_msgPUBLISH() Create PUBLISH message
  *
@@ -272,6 +274,20 @@ inline int mqtt_msgPUBREL(mqtt_msg_t * __restrict buf,
  * return: -1 error or >-1 message size for send
  */
 inline int mqtt_msgPUBCOMP(mqtt_msg_t * __restrict buf, unsigned short msgID);
+
+/*
+ * mqtt_msgSUBSCRIBE() Create SUBSCRIBE message
+ *
+ * @buf = Message buffer
+ * @Topics = MQTT subscription topics
+ * @msgID = MessageID
+ * @Dup = Duplicate message
+ * @QOS = QoS
+ * return: -1 error or >-1 message size for send
+ */
+int
+mqtt_msgSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, 
+		unsigned short msgID, unsigned char Dup, unsigned char QOS);
 
 
 #endif