--- mqtt/inc/mqtt.h	2012/01/27 15:05:38	1.2
+++ mqtt/inc/mqtt.h	2012/05/01 22:19:29	1.2.2.3
@@ -2,7 +2,12 @@
 #define __MQTT_H
 
 
+#define API_CLIENT_SIDE
+#include <mqttapi.h>
+
+
 struct tagArgs {
+	mqtt_cli_t	*cli;
 	io_sockaddr_t	addr;
 	u_short		ka;
 	mqtt_msg_t	*msg;
@@ -30,7 +35,7 @@ struct tagArgs {
 
 	ait_val_t	Publish;
 
-	array_t		*Subscribes;
+	mqtt_subscr_t	*subscr;
 
 	void		(*free)(struct tagArgs*);
 };