--- mqtt/src/logmqtt.c	2011/11/24 00:08:56	1.1.2.3
+++ mqtt/src/logmqtt.c	2012/07/03 09:02:50	1.3
@@ -30,7 +30,7 @@ mqtt_rtlm_log(const char *fmt, ...)
  * return: NULL error or SQL handle
  */
 FILE *
-mqtt_rtlm_open(sl_config *cfg)
+mqtt_rtlm_open(cfg_root_t *cfg)
 {
 	FILE *f = NULL;
 	const char *str = NULL;
@@ -38,7 +38,7 @@ mqtt_rtlm_open(sl_config *cfg)
 	if (!cfg)
 		return NULL;
 
-	str = (const char*) cfg_GetAttribute(cfg, CFG("mqtt_log"), CFG("name"));
+	str = cfg_getAttribute(cfg, "mqtt_log", "name");
 	if (!str) {
 		mqtt_rtlm_log("Error:: Unknown file name ...\n");
 		return NULL;
@@ -96,5 +96,6 @@ mqtt_rtlm_logger(FILE *f, const char *fmt, ...)
 	ret = vfprintf(f, szFmt, lst);
 	va_end(lst);
 
+	fflush(f);
 	return ret;
 }