--- mqtt/src/mqtt_pub.c	2011/12/24 17:30:29	1.1.2.3
+++ mqtt/src/mqtt_pub.c	2011/12/29 14:13:13	1.1.2.4
@@ -49,7 +49,9 @@ cleanArgs(struct tagArgs * __restrict args)
 static int
 Publish(int sock)
 {
-	return 0;
+	int siz = 0;
+
+	return siz;
 }
 
 
@@ -166,6 +168,12 @@ main(int argc, char **argv)
 		return 2;
 	}
 
+	if (args->isFile && !OpenFile()) {
+		args->free(args);
+		free(args);
+		return 3;
+	}
+
 	printf("Connected ... ");
 	switch ((ret = ConnectClient(sock))) {
 		case -1:
@@ -197,9 +205,10 @@ main(int argc, char **argv)
 		CloseClient(sock);
 	} else {
 		close(sock);
-		ret = 3;
+		ret = 4;
 	}
 
+	CloseFile();
 	args->free(args);
 	free(args);
 	return ret;