--- mqtt/src/mqttd_calls.c	2012/05/05 14:51:02	1.2.2.10
+++ mqtt/src/mqttd_calls.c	2012/05/05 15:16:34	1.2.2.12
@@ -185,8 +185,7 @@ cmdCONNECT(void *srv, int len, void *arg)
 	call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid, 
 			sess->sess_addr, sess->sess_user);
 
-//	schedEvent(root, startSession, NULL, (u_long) sess->sess_sock, sess, ret);
-	return 0;
+	return -3;	/* reconnect client */
 }
 
 int
@@ -200,8 +199,6 @@ cmdDISCONNECT(void *srv, int len, void *arg)
 		return -1;
 
 	ioDEBUG(5, "Exec DISCONNECT session");
-
-	TAILQ_REMOVE(&Sessions, sess, sess_node);
 
 	call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid, 
 			sess->sess_addr, sess->sess_user);