--- mqtt/src/Attic/sub.c	2011/11/28 10:17:12	1.1.2.8
+++ mqtt/src/Attic/sub.c	2011/12/05 22:17:39	1.1.2.9
@@ -217,3 +217,34 @@ mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, u_short 
 
 	return siz;
 }
+
+
+/* ============= decode ============ */
+
+/*
+ * mqtt_readUNSUBACK() Read UNSUBACK message
+ *
+ * @buf = Message buffer
+ * return: -1 error or MessageID
+ */
+u_short
+mqtt_readUNSUBACK(mqtt_msg_t * __restrict buf)
+{
+	int len, ret;
+	struct mqtthdr *hdr;
+	mqtt_v_t *v;
+	caddr_t pos;
+
+	hdr = _mqtt_readHEADER(buf, MQTT_TYPE_UNSUBACK, &ret, &len);
+	if (!hdr)
+		return (u_short) -1;
+	if (len < sizeof(mqtt_v_t)) {
+		mqtt_SetErr(EINVAL, "Error:: short message length %d", len);
+		return (u_short) -1;
+	} else {
+		pos = buf->msg_base + ret + 1;
+		v = (mqtt_v_t*) pos;
+	}
+
+	return ntohs(v->val);
+}