--- mqtt/src/daemon.c	2011/12/14 12:45:30	1.1.2.18
+++ mqtt/src/daemon.c	2011/12/14 13:15:35	1.1.2.19
@@ -37,7 +37,7 @@ initSession(int sock, ait_val_t * __restrict v)
 	}
 
 	sess->sess_sock = sock;
-	strlcpy(sess->sess_addr, AIT_GET_STR(v), sizeof sess->sess_addr);
+	strlcpy(sess->sess_addr, (char*) AIT_GET_STR(v), sizeof sess->sess_addr);
 	io_freeVar(v);
 	return sess;
 }
@@ -150,7 +150,8 @@ startSession(sched_task_t *task)
 		return NULL;
 	} else {
 		VERB(5) ioLOGGER(LOG_DEBUG, "Sended %d bytes", ret);
-		mqtt_msgFree((mqtt_msg_t**) &msg, 0);
+		free(msg.msg_base);
+		msg.msg_len = 0;
 	}
 
 	/* Start session thread OK ... */
@@ -173,7 +174,8 @@ end:	/* close client connection */
 		VERB(3) syslog(LOG_ERR, "Error:: send(%d) #%d - %s", sess->sess_sock, errno, strerror(errno));
 	} else {
 		VERB(5) ioLOGGER(LOG_DEBUG, "Sended %d bytes", ret);
-		mqtt_msgFree((mqtt_msg_t**) &msg, 0);
+		free(msg.msg_base);
+		msg.msg_len = 0;
 	}
 
 	VERB(1) ioLOGGER(LOG_DEBUG, "Close client %s with socket=%d", sess->sess_addr, sess->sess_sock);