diff --git a/src/mod/applications/mod_fifo/mod_fifo.c b/src/mod/applications/mod_fifo/mod_fifo.c index 00b411572c..ae46280900 100644 --- a/src/mod/applications/mod_fifo/mod_fifo.c +++ b/src/mod/applications/mod_fifo/mod_fifo.c @@ -4040,6 +4040,21 @@ static switch_status_t load_config(int reload, int del_all) } if (!reload) { + + + switch_sql_queue_manager_init_name("fifo", + &globals.qm, + 2, + globals.odbc_dsn ? globals.odbc_dsn : globals.dbname, + SWITCH_MAX_TRANS, + globals.pre_trans_execute, + globals.post_trans_execute, + globals.inner_pre_trans_execute, + globals.inner_post_trans_execute); + + + + switch_cache_db_test_reactive(dbh, "delete from fifo_outbound where static = 1 or taking_calls < 0 or stop_time < 0", "drop table fifo_outbound", outbound_sql); switch_cache_db_test_reactive(dbh, "delete from fifo_bridge", "drop table fifo_bridge", bridge_sql); @@ -4485,18 +4500,6 @@ SWITCH_MODULE_LOAD_FUNCTION(mod_fifo_load) return status; } - if (globals.odbc_dsn || globals.dbname) { - switch_sql_queue_manager_init_name("fifo", - &globals.qm, - 2, - globals.odbc_dsn ? globals.odbc_dsn : globals.dbname, - SWITCH_MAX_TRANS, - globals.pre_trans_execute, - globals.post_trans_execute, - globals.inner_pre_trans_execute, - globals.inner_post_trans_execute); - } - /* connect my internal structure to the blank pointer passed to me */ *module_interface = switch_loadable_module_create_module_interface(pool, modname);