--- mqtt/src/pubmqtt.c	2011/11/24 15:34:18	1.1.2.6
+++ mqtt/src/pubmqtt.c	2011/11/24 16:00:31	1.1.2.7
@@ -181,8 +181,10 @@ mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, co
 		MQTT_RTLM_LOG(sql);
 		return -1;
 	}
-	while (sqlite3_step(stmt) == SQLITE_ROW);
-	ret = sqlite3_changes(sql);
+	if (sqlite3_step(stmt) == SQLITE_ROW)
+		ret = sqlite3_changes(sql);
+	else
+		ret = 0;
 	sqlite3_finalize(stmt);
 
 	return ret;