--- mqtt/src/daemon.c	2012/07/03 07:52:36	1.2.2.45
+++ mqtt/src/daemon.c	2012/07/03 07:57:16	1.2.2.46
@@ -405,6 +405,8 @@ Run(int sock)
 	schedPolling(root, &pl, NULL);
 	schedRun(root, &Kill);
 
+	schedCancelby(root, taskTIMER, CRITERIA_CALL, sendRetain, NULL);
+
 	/* free all undeleted elements into lists */
 	TAILQ_FOREACH(sess, &Sessions, sess_node) {
 		TAILQ_REMOVE(&Sessions, sess, sess_node);