--- mqtt/src/mqtt_pub.c	2011/12/20 16:04:34	1.1.2.2
+++ 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,8 +168,14 @@ main(int argc, char **argv)
 		return 2;
 	}
 
+	if (args->isFile && !OpenFile()) {
+		args->free(args);
+		free(args);
+		return 3;
+	}
+
 	printf("Connected ... ");
-	switch ((ret = try2Connect(sock))) {
+	switch ((ret = ConnectClient(sock))) {
 		case -1:
 			printf(">> FAILED!\n");
 			break;
@@ -194,10 +202,13 @@ main(int argc, char **argv)
 	if (ret == MQTT_RETCODE_ACCEPTED) {
 		ret = Publish(sock);
 		shutdown(sock, SHUT_RDWR);
-	} else
-		ret = 3;
+		CloseClient(sock);
+	} else {
+		close(sock);
+		ret = 4;
+	}
 
-	close(sock);
+	CloseFile();
 	args->free(args);
 	free(args);
 	return ret;