--- mqtt/inc/mqttd.h	2012/05/22 14:15:04	1.2.2.11
+++ mqtt/inc/mqttd.h	2012/06/01 10:39:48	1.2.2.12
@@ -14,6 +14,12 @@ struct tagStore {
 	SLIST_ENTRY(tagStore)		st_node;
 };
 
+struct tagPkt {
+	ait_val_t			*pkt_data;
+
+	SLIST_ENTRY(tagPkt)		pkt_node;
+};
+
 struct tagSession {
 	/* server dispatcher */
 	mqtt_srv_t			*sess_srv;
@@ -42,8 +48,9 @@ struct tagSession {
 		char			*msg;
 	} sess_will;
 
-	/* session subscriptions */
+	/* session subscriptions & send pubs */
 	SLIST_HEAD(tStore, tagStore)	sess_subscr;
+	SLIST_HEAD(tPkt, tagPkt)	sess_sndpkt;
 
 	TAILQ_ENTRY(tagSession)		sess_node;
 };