--- mqtt/inc/Attic/aitmqtt.h	2011/12/05 10:37:17	1.1.1.1.2.23
+++ mqtt/inc/Attic/aitmqtt.h	2011/12/05 22:17:39	1.1.1.1.2.27
@@ -364,6 +364,95 @@ int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsi
 /*** RECEIVER FUNCTIONS ***/
 
 /*
+ * mqtt_readCONNECT() Read elements from CONNECT message
+ *
+ * @buf = Message buffer
+ * @kasec = Keep Alive in seconds for current connection
+ * @psConnID = ConnectID
+ * @connLen = ConnectID length
+ * @psUser = Username if !=NULL
+ * @userLen = Username length
+ * @psPass = Password for Username, only if csUser is set
+ * @passLen = Password length
+ * @psWillTopic = Will Topic if !=NULL Will Flags set into message
+ * @topicLen = Will Topic length
+ * @psWillMessage = Will Message, may be NULL
+ * @msgLen = Will Message length
+ * return: .reserved == 1 is error or == 0 connection flags & msg ok
+ */
+mqtthdr_connflgs_t mqtt_readCONNECT(mqtt_msg_t * __restrict buf, unsigned short *kasec, 
+		char * __restrict psConnID, int connLen, 
+		char * __restrict psUser, int userLen, char * __restrict psPass, int passLen,  
+		char * __restrict psWillTopic, int topicLen, char * __restrict psWillMessage, int msgLen);
+/*
+ * mqtt_readCONNACK() Read CONNACK message
+ *
+ * @buf = Message buffer
+ * return: -1 error or >-1 CONNECT message return code
+ */
+unsigned char mqtt_readCONNACK(mqtt_msg_t * __restrict buf);
+/*
+ * mqtt_readDISCONNECT() Read DISCONNECT message
+ *
+ * @buf = Message buffer
+ * return: -1 error, 0 ok, >0 undefined result
+ */
+int mqtt_readDISCONNECT(mqtt_msg_t * __restrict buf);
+/*
+ * mqtt_readPINGREQ() Read PINGREQ message
+ *
+ * @buf = Message buffer
+ * return: -1 error, 0 ok, >0 undefined result
+ */
+int mqtt_readPINGREQ(mqtt_msg_t * __restrict buf);
+/*
+ * mqtt_readPINGRESP() Read PINGRESP message
+ *
+ * @buf = Message buffer
+ * return: -1 error, 0 ok, >0 undefined result
+ */
+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 ***/
+
+/*
  * mqttInitCallbacks() Init callback array for dispatcher
  *
  * return: NULL error or !=NULL allocated callback array, after use free with mqttFiniCallbacks()