revert

diff --git a/src/switch_core_sqldb.c b/src/switch_core_sqldb.c
index 5395f502c2d846e5104b1777177ea6ddb3d5b88f..7fc32c0a3f272b7e6de79643a079e1934ba1ea4c 100644 (file)
--- a/src/switch_core_sqldb.c
+++ b/src/switch_core_sqldb.c
@@ -35,8 +35,6 @@
 #include <switch.h>
 #include "private/switch_core_pvt.h"
 
-#define SQL_QUEUE_MAX = 
-
 static struct {
        switch_cache_db_handle_t *event_db;
        switch_queue_t *sql_queue[2];
@@ -1255,13 +1253,14 @@ static void core_event_handler(switch_event_t *event)
        }
 
        if (sql_idx) {
-               int i = 0, x = 0;
+               int i = 0;
 
                for (i = 0; i < sql_idx; i++) {
-                       if (!switch_stristr("insert", sql[i])) {
-                               x = 1;
+                       if (switch_stristr("update channels", sql[i]) || switch_stristr("delete from channels", sql[i])) {
+                               switch_queue_push(sql_manager.sql_queue[1], sql[i]);
+                       } else {
+                               switch_queue_push(sql_manager.sql_queue[0], sql[i]);
                        }
-                       switch_queue_push(sql_manager.sql_queue[x], sql[i]);
                        sql[i] = NULL;
                }
        }