--- mqtt/src/mqtt_subs.c	2011/12/20 16:04:34	1.1.2.1
+++ mqtt/src/mqtt_subs.c	2012/01/27 15:05:38	1.2
@@ -190,7 +190,7 @@ main(int argc, char **argv)
 	}
 
 	printf("Connected ... ");
-	switch ((ret = try2Connect(sock))) {
+	switch ((ret = ConnectClient(sock))) {
 		case -1:
 			printf(">> FAILED!\n");
 			break;
@@ -225,10 +225,12 @@ main(int argc, char **argv)
 			shutdown(sock, SHUT_RDWR);
 		} else
 			printf("Error:: in subscribe file #%d - %s\n", errno, strerror(errno));
-	} else
+		CloseClient(sock);
+	} else {
+		close(sock);
 		ret = 3;
+	}
 
-	close(sock);
 	args->free(args);
 	free(args);
 	return ret;