--- mqtt/src/mqtt_pub.c	2012/01/05 13:09:05	1.1.2.7
+++ mqtt/src/mqtt_pub.c	2012/01/24 10:18:45	1.1.2.8
@@ -239,6 +239,7 @@ main(int argc, char **argv)
 	}
 
 	printf("Connected ... ");
+	ConnectClient(sock); ConnectClient(sock);
 	switch ((ret = ConnectClient(sock))) {
 		case -1:
 			printf(">> FAILED!\n");
@@ -262,6 +263,7 @@ main(int argc, char **argv)
 			printf(">> DENIED.\n");
 			break;
 	}
+	sleep(1);
 
 	if (ret == MQTT_RETCODE_ACCEPTED) {
 		ret = !(Publish(sock) == args->MsgID);