--- mqtt/src/daemon.c	2012/01/25 10:34:14	1.1.2.32
+++ mqtt/src/daemon.c	2012/01/27 15:18:12	1.2.2.1
@@ -65,10 +65,10 @@ finiSession(struct tagSession *sess, int preservSock)
 	while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {
 		TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);
 
-		if (store->st_subscr.sub_topic._base)
-			free(store->st_subscr.sub_topic._base);
-		if (store->st_subscr.sub_value._base)
-			free(store->st_subscr.sub_value._base);
+		if (store->st_subscr.sub_topic.msg_base)
+			free(store->st_subscr.sub_topic.msg_base);
+		if (store->st_subscr.sub_value.msg_base)
+			free(store->st_subscr.sub_value.msg_base);
 
 		free(store);
 	}
@@ -211,10 +211,10 @@ thrSession(struct tagSession *sess)
 				while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {
 					TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);
 
-					if (store->st_subscr.sub_topic._base)
-						free(store->st_subscr.sub_topic._base);
-					if (store->st_subscr.sub_value._base)
-						free(store->st_subscr.sub_value._base);
+					if (store->st_subscr.sub_topic.msg_base)
+						free(store->st_subscr.sub_topic.msg_base);
+					if (store->st_subscr.sub_value.msg_base)
+						free(store->st_subscr.sub_value.msg_base);
 
 					free(store);
 				}