--- mqtt/src/mqtt_pub.c	2012/01/24 10:18:45	1.1.2.8
+++ mqtt/src/mqtt_pub.c	2012/04/11 15:08:27	1.2.2.2
@@ -53,7 +53,7 @@ Publish(int sock)
 	int siz = 0;
 
 	siz = mqtt_msgPUBLISH(args->msg, AIT_GET_STR(&args->Publish), args->MsgID, args->Dup, 
-			args->QoS, args->Retain, AIT_GET_PTR2(&args->Value), AIT_LEN(&args->Value));
+			args->QoS, args->Retain, AIT_ADDR(&args->Value), AIT_LEN(&args->Value));
 	if (siz == -1) {
 		printf("Error:: msgPUBLISH #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
 		return -1;
@@ -224,7 +224,8 @@ main(int argc, char **argv)
 	}
 	if (args->QoS && !args->MsgID)
 		args->MsgID = MQTT_DEFAULT_MSGID;
-	ioVERBOSE(1) printf("Connecting to %s:%d ...\n", io_n2addr(&args->addr, &val), io_n2port(&args->addr));
+	printf("Connecting to %s:%d ... ", io_n2addr(&args->addr, &val), io_n2port(&args->addr));
+	AIT_FREE_VAL(&val);
 
 	if ((sock = InitClient()) == -1) {
 		args->free(args);
@@ -238,8 +239,6 @@ main(int argc, char **argv)
 		return 3;
 	}
 
-	printf("Connected ... ");
-	ConnectClient(sock); ConnectClient(sock);
 	switch ((ret = ConnectClient(sock))) {
 		case -1:
 			printf(">> FAILED!\n");
@@ -263,7 +262,6 @@ main(int argc, char **argv)
 			printf(">> DENIED.\n");
 			break;
 	}
-	sleep(1);
 
 	if (ret == MQTT_RETCODE_ACCEPTED) {
 		ret = !(Publish(sock) == args->MsgID);