--- mqtt/src/mqttd_calls.c 2012/07/03 07:48:49 1.2.2.34 +++ mqtt/src/mqttd_calls.c 2012/07/03 07:57:16 1.2.2.35 @@ -128,6 +128,7 @@ sendRetain(sched_task_t *task) search4send(sess, s->sub_topic.msg_base, siz, s->sub_ret); } + mqtt_subFree(&subs); return NULL; }