--- mqtt/inc/mqtt.h	2011/12/12 09:45:16	1.1.2.2
+++ mqtt/inc/mqtt.h	2011/12/13 14:57:14	1.1.2.6
@@ -4,18 +4,32 @@
 
 struct tagArgs {
 	io_sockaddr_t	addr;
+	mqtt_msg_t	*msg;
 
-	char		Dup;
-	char		Retain;
-	char		QoS;
-	char		*psPublish;
+	ait_val_t	ConnID;
+	ait_val_t	User;
+	ait_val_t	Pass;
+
 	struct {
-		char	*psValue;
-		char	*psFile;
+		ait_val_t	Topic;
+		ait_val_t	Msg;
+	} Will;
+
+	u_char		Dup;
+	u_char		Retain;
+	u_char		QoS;
+	u_char		Clear;
+
+	struct {
+		u_char		isFile;
+		ait_val_t	Value;
 	};
 
-	int		subsLen;
-	char		*psSubscribe[1];
+	ait_val_t	Publish;
+
+	array_t		*Subscribes;
+
+	void		(*free)(struct tagArgs*);
 };
 
 extern struct tagArgs *args;