--- mqtt/src/mqtt_subs.c	2012/05/28 08:24:07	1.2.2.10
+++ mqtt/src/mqtt_subs.c	2012/06/01 13:13:40	1.2.2.11
@@ -181,7 +181,7 @@ main(int argc, char **argv)
 						sub->sub_ret = (u_char) *str;
 				} else
 					sub->sub_ret = (u_char) args->QoS;
-				sub->sub_topic.msg_base = io_strdup(szStr);
+				sub->sub_topic.msg_base = strdup(szStr);
 				sub->sub_topic.msg_len = strlen(szStr);
 				break;
 			case 'q':