--- mqtt/src/Attic/sub.c	2011/11/21 15:07:12	1.1.2.2
+++ mqtt/src/Attic/sub.c	2011/11/21 15:27:26	1.1.2.3
@@ -5,6 +5,52 @@
 
 int
 mqtt_msgSUBSCRIBE(mqtt_msg_t * __restrict buf, const char *csTopic, u_short msgID, 
-		)
+		u_char Dup, u_char QOS)
 {
+	int siz = 0;
+#if 0
+	struct mqtthdr *hdr;
+	mqtthdr_var_t *topic;
+	mqtt_v_t *mid;
+
+	if (!buf || !csTopic)
+		return -1;
+	if (QOS > MQTT_QOS_EXACTLY) {
+		mqtt_SetErr(EINVAL, "Error:: invalid QoS parameter");
+		return -1;
+	}
+	if (!msgID && QOS != MQTT_QOS_ONCE) {
+		mqtt_SetErr(EINVAL, "Error:: invalid MessageID parameter must be >0");
+		return -1;
+	}
+
+	if (mqtt_msgRealloc(buf, MQTTMSG_MAX) == -1)
+		return -1;
+	else {
+		hdr = (struct mqtthdr *) (buf->msg_base + siz);
+		siz += sizeof(struct mqtthdr);
+	}
+
+	/* variable header */
+
+	topic = (mqtthdr_var_t*) (buf->msg_base + siz);
+	topic->var_sb.val = htons(strlen(csTopic));
+	memcpy(topic->var_data, csTopic, ntohs(topic->var_sb.val));
+	siz += MQTTHDR_VAR_SIZEOF(topic);
+
+	mid = (mqtt_v_t*) (buf->msg_base + siz);
+	mid->val = htons(msgID);
+	siz += sizeof(mqtt_v_t);
+
+	/* fixed header */
+
+	hdr->mqtt_msg.type = MQTT_TYPE_PUBLISH;
+	hdr->mqtt_msg.qos = QOS;
+	hdr->mqtt_msg.dup = Dup ? 1 : 0;
+	hdr->mqtt_msg.retain = Retain ? 1 : 0;
+	*hdr->mqtt_len = mqtt_encodeLen(siz - sizeof(struct mqtthdr));
+
+	mqtt_msgRealloc(buf, siz);
+#endif
+	return siz;
 }