增加日志

thirdparty/mqtt/cmd_transport_mqtt.cpp

@@ -15,6 +15,11 @@ static struct Options
 	int iterations;
 } options;
 
+void mqtt_trace_callback(enum MQTTASYNC_TRACE_LEVELS level, char* message)
+{
+	if(level == MQTTASYNC_TRACE_ERROR)
+	 printf("--------------mqtt trace : %s\n", message);
+}
 CmdTransportMqtt::CmdTransportMqtt(std::string uu_id, std::string room_id, TransportObserver *observer)
 	:observer_(observer),
 	uu_id_(uu_id),
@@ -24,6 +29,8 @@ CmdTransportMqtt::CmdTransportMqtt(std::string uu_id, std::string room_id, Trans
 }
 bool CmdTransportMqtt::ConnectServer(std::string mqtt)
 {
+	printf("mqtt url : %s\nroomid : %s\n", mqtt.c_str(), room_id_.c_str());
+
 	options.connection = (char *)malloc(128);
 	memset(options.connection, 0, 128);
 	memcpy(options.connection, mqtt.c_str(), mqtt.size());
@@ -42,6 +49,7 @@ bool CmdTransportMqtt::ConnectServer(std::string mqtt)
 	int nRet = MQTTAsync_create(&mqtt_client_, options.connection, clientid.c_str(), MQTTCLIENT_PERSISTENCE_NONE/*MQTTCLIENT_PERSISTENCE_DEFAULT*/, NULL);
 
 	nRet = MQTTAsync_setCallbacks(mqtt_client_, this, NULL, mqtt_messageArrive, NULL);
+	MQTTAsync_setTraceCallback(mqtt_trace_callback);
 
 	std::string new_token = kPassWord;
 	opts.keepAliveInterval = 20;