Module: kamailio Branch: master Commit: 06e356110a60af5301d0f61f73268748e771e5c4 URL: https://github.com/kamailio/kamailio/commit/06e356110a60af5301d0f61f73268748e771e5c4
Author: Stefan Mititelu <[email protected]> Committer: Daniel-Constantin Mierla <[email protected]> Date: 2026-05-11T21:34:53+02:00 dialog: add new modparam dmq_peer_id --- Modified: src/modules/dialog/dialog.c Modified: src/modules/dialog/dlg_dmq.c Modified: src/modules/dialog/doc/dialog_admin.xml --- Diff: https://github.com/kamailio/kamailio/commit/06e356110a60af5301d0f61f73268748e771e5c4.diff Patch: https://github.com/kamailio/kamailio/commit/06e356110a60af5301d0f61f73268748e771e5c4.patch --- diff --git a/src/modules/dialog/dialog.c b/src/modules/dialog/dialog.c index 0c51dc88367..81c0361a841 100644 --- a/src/modules/dialog/dialog.c +++ b/src/modules/dialog/dialog.c @@ -117,6 +117,7 @@ int dlg_noack_timeout = 60; int dlg_end_timeout = 300; int dlg_enable_dmq = 0; +str dlg_dmq_peer_id = str_init("dialog"); int dlg_event_rt[DLG_EVENTRT_MAX]; str dlg_event_callback = STR_NULL; @@ -388,6 +389,7 @@ static param_export_t mod_params[]={ { "dlg_ctxiuid_mode", PARAM_INT, &dlg_ctxiuid_mode }, { "debug_variables", PARAM_INT, &debug_variables_list }, { "dlg_mode", PARAM_INT, &dlg_process_mode }, + { "dmq_peer_id", PARAM_STR, &dlg_dmq_peer_id }, { 0,0,0 } }; diff --git a/src/modules/dialog/dlg_dmq.c b/src/modules/dialog/dlg_dmq.c index 39f4a10390a..356d560cf28 100644 --- a/src/modules/dialog/dlg_dmq.c +++ b/src/modules/dialog/dlg_dmq.c @@ -39,6 +39,7 @@ int dmq_send_all_dlgs(dmq_node_t *dmq_node); int dlg_dmq_request_sync(dmq_node_t *dmq_node); extern int dlg_enable_stats; +extern str dlg_dmq_peer_id; /** * @brief add notification peer @@ -57,10 +58,8 @@ int dlg_dmq_initialize() not_peer.callback = dlg_dmq_handle_msg; not_peer.init_callback = dlg_dmq_request_sync; - not_peer.description.s = "dialog"; - not_peer.description.len = 6; - not_peer.peer_id.s = "dialog"; - not_peer.peer_id.len = 6; + not_peer.peer_id = dlg_dmq_peer_id; + not_peer.description = dlg_dmq_peer_id; dlg_dmq_peer = dlg_dmqb.register_dmq_peer(¬_peer); if(!dlg_dmq_peer) { LM_ERR("error in register_dmq_peer\n"); diff --git a/src/modules/dialog/doc/dialog_admin.xml b/src/modules/dialog/doc/dialog_admin.xml index c70ac2de0d5..045ef947f70 100644 --- a/src/modules/dialog/doc/dialog_admin.xml +++ b/src/modules/dialog/doc/dialog_admin.xml @@ -1745,6 +1745,27 @@ modparam("dialog", "debug_variables", 1) ... modparam("dialog", "dlg_mode", 1) ... +</programlisting> + </example> + </section> + <section id="dialog.p.dmq_peer_id"> + <title><varname>dmq_peer_id</varname> (string)</title> + <para> + The DMQ peer identifier for dialog replication. This allows + customizing the peer name used in DMQ communication, which can be useful + to avoid compatibility conflicts, and for a better partitioning. + </para> + <para> + <emphasis> + Default value is <quote>dialog</quote>. + </emphasis> + </para> + <example> + <title>Set <varname>dmq_peer_id</varname> parameter</title> + <programlisting format="linespecific"> +... +modparam("dialog", "dmq_peer_id", "dialog_6.1.1") +... </programlisting> </example> </section> _______________________________________________ Kamailio - Development Mailing List -- [email protected] To unsubscribe send an email to [email protected] Important: keep the mailing list in the recipients, do not reply only to the sender!
