--- mqtt/src/pubmqtt.c	2011/11/24 13:57:12	1.1.2.4
+++ mqtt/src/pubmqtt.c	2011/11/24 15:14:08	1.1.2.5
@@ -106,3 +106,46 @@ mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, c
 
 	return ret;
 }
+
+/*
+ * mqtt_rtlm_fini_session() Delete session(s)
+ *
+ * @cfg = loaded config
+ * @sql = SQL handle
+ * @user = username
+ * @host = hostname
+ * return: -1 error, 0 session already appears or >0 row changed
+ */
+int
+mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, const char *user, const char *host)
+{
+	int ret = 0;
+	char *str, szStmt[BUFSIZ] = { 0 };
+	sqlite3_stmt *stmt;
+
+	if (!cfg || !sql)
+		return -1;
+
+	str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_online"));
+	if (!str) {
+		mqtt_rtlm_log("Error:: not found topics table name");
+		return -1;
+	}
+	snprintf(szStmt, sizeof szStmt, "DELETE FROM %s WHERE Username = '%s' AND RemoteHost LIKE '%s';", 
+			str, user, host);
+
+	if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {
+		MQTT_RTLM_LOG(sql);
+		return -1;
+	}
+	if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
+		ret = sqlite3_changes(sql);
+	else {
+		if (ret > SQLITE_OK && ret < SQLITE_ROW)
+			MQTT_RTLM_LOG(sql);
+		ret = 0;
+	}
+	sqlite3_finalize(stmt);
+
+	return ret;
+}