--- mqtt/src/Attic/pub.c	2011/12/06 09:04:55	1.1.2.8
+++ mqtt/src/Attic/pub.c	2011/12/06 10:33:37	1.1.2.9
@@ -185,13 +185,8 @@ mqtt_readPUBLISH(mqtt_msg_t * __restrict buf, char * _
 	hdr = _mqtt_readHEADER(buf, MQTT_TYPE_PUBLISH, &ret, &len);
 	if (!hdr)
 		return NULL;
-	if (len < sizeof(mqtt_v_t)) {
-		mqtt_SetErr(EINVAL, "Error:: short message length %d", len);
-		return NULL;
-	} else {
-		pos = buf->msg_base + ret + 1;
-		var = (mqtthdr_var_t*) pos;
-	}
+	pos = buf->msg_base + ret + 1;
+	var = (mqtthdr_var_t*) pos;
 
 	/* topic */
 	len -= MQTTHDR_VAR_SIZEOF(var);