- avoiding redeclaration, it is set via modparam (cherry picked from commit 02bff604ec70a51a5ba9faae38e946e556763e08)
@@ -48,7 +48,7 @@ static str dmq_500_rpl = str_init("Server Internal Error");
static int dmq_cell_group_empty_size = 12; // {"cells":[]}
static int dmq_cell_group_max_size = 60000;
static ht_dmq_jdoc_cell_group_t ht_dmq_jdoc_cell_group;
-int ht_dmq_init_sync;
+extern int ht_dmq_init_sync;
dmq_api_t ht_dmqb;
dmq_peer_t* ht_dmq_peer = NULL;
@@ -31,8 +31,6 @@ extern dmq_api_t ht_dmqb;
extern dmq_peer_t* ht_dmq_peer;
extern dmq_resp_cback_t ht_dmq_resp_callback;
-
typedef enum {
HT_DMQ_NONE,
HT_DMQ_SET_CELL,
@@ -220,7 +220,7 @@ static int mod_init(void)
}
- if (ht_enable_dmq>0 && ht_dmq_initialize(ht_dmq_init_sync)!=0) {
+ if (ht_enable_dmq>0 && ht_dmq_initialize()!=0) {
LM_ERR("failed to initialize dmq integration\n");
return -1;