--- mqtt/src/daemon.c 2011/12/16 13:34:41 1.1.2.28 +++ mqtt/src/daemon.c 2012/01/05 10:01:20 1.1.2.29 @@ -184,6 +184,7 @@ thrSession(struct tagSession *sess) } else hdr = (struct mqtthdr*) buf.msg_base; + /* dispatch message type */ switch (hdr->mqtt_msg.type) { default: ioDEBUG(5, "Error:: Session %s, wrong command %d - DISCARDED",