diff --git a/src/switch_core_sqldb.c b/src/switch_core_sqldb.c
index 6e449b6f7b..708577d823 100644
--- a/src/switch_core_sqldb.c
+++ b/src/switch_core_sqldb.c
@@ -1605,7 +1605,7 @@ static void *SWITCH_THREAD_FUNC switch_user_sql_thread(switch_thread_t *thread,
 		}
 		
 		for (i = 0; i < qm->numq; i++) {
-			uint32_t written = do_trans(qm->event_db, qm->sql_queue[i], NULL,
+			uint32_t written = do_trans(qm->event_db, qm->sql_queue[i], qm->mutex,
 										qm->pre_trans_execute,
 										qm->post_trans_execute,
 										qm->inner_pre_trans_execute,