--- mqtt/src/daemon.c 2012/04/26 09:15:26 1.2.2.18 +++ mqtt/src/daemon.c 2012/04/27 10:07:50 1.2.2.19 @@ -176,6 +176,9 @@ thrSession(struct tagSession *sess) finiSession(sess); locKill ^= locKill; continue; + case MQTT_TYPE_SUBSCRIBE: + case MQTT_TYPE_PINGREQ: + break; case MQTT_TYPE_PUBLISH: ioDEBUG(5, "Exec PUBLISH topic QoS=%d", hdr->mqtt_msg.qos); /* @@ -185,15 +188,7 @@ thrSession(struct tagSession *sess) break; case MQTT_TYPE_PUBREL: break; - case MQTT_TYPE_SUBSCRIBE: - break; case MQTT_TYPE_UNSUBSCRIBE: - break; - case MQTT_TYPE_PINGREQ: - ioDEBUG(5, "Exec PINGREQ session"); - break; - case MQTT_TYPE_PINGRESP: - ioDEBUG(5, "Exec PINGRESP session"); break; default: ioDEBUG(5, "Error:: Session %s, wrong command %d - DISCARDED",