From c85d9543163d6120df666e318a0dcb8298371d43 Mon Sep 17 00:00:00 2001
From: lazedo <luis.azedo@factorlusitano.com>
Date: Sat, 13 May 2017 10:22:31 +0100
Subject: [PATCH] allow optional dispatcher server add

---
 kamailio/defs.cfg            |  4 ++++
 kamailio/dispatcher-role.cfg | 20 ++++++++++++--------
 2 files changed, 16 insertions(+), 8 deletions(-)

diff --git a/kamailio/defs.cfg b/kamailio/defs.cfg
index 34e8917..e2aeb57 100644
--- a/kamailio/defs.cfg
+++ b/kamailio/defs.cfg
@@ -55,4 +55,8 @@
 #!substdef "!MY_AMQP_ZONE!local!g"
 #!endif
 
+#!ifndef DISPATCHER_ADD_SERVERS
+#!define DISPATCHER_ADD_SERVERS 1
+#!endif
+
 # vim: tabstop=4 softtabstop=4 shiftwidth=4 expandtab
diff --git a/kamailio/dispatcher-role.cfg b/kamailio/dispatcher-role.cfg
index 89ccfd2..49faa01 100644
--- a/kamailio/dispatcher-role.cfg
+++ b/kamailio/dispatcher-role.cfg
@@ -1,6 +1,8 @@
 ######## Generic Hash Table container in shared memory ########
 modparam("htable", "htable", "failover=>size=16;autoexpire=120")
 
+kazoo.dispatcher_auto_add = DISPATCHER_ADD_SERVERS descr "adds media servers reported by ecallmgr"
+
 ####### Dispatcher module  ########
 loadmodule "dispatcher.so"
 modparam("dispatcher", "db_url", "KAZOO_DB_URL")
@@ -214,14 +216,16 @@ event_route[dispatcher:dst-up]
 
 route[DISPATCHER_CHECK_MEDIA_SERVER]
 {
-   $var(SetId) = 1;
-   if($var(Zone) != "MY_AMQP_ZONE") {
-      $var(SetId) = 2;
-   }
-   sql_query("exec", "insert into dispatcher (setid, destination) select $var(SetId), \"$var(MediaUrl)\" where not exists(select * from dispatcher where destination = \"$var(MediaUrl)\")");
-   if($sqlrows(exec) > 0) {
-      xlog("L_WARNING", "reloading dispatcher table\n");
-      ds_reload();
+   if(@cfg_get.kazoo.dispatcher_auto_add == 1) {
+       $var(SetId) = 1;
+       if($var(Zone) != "MY_AMQP_ZONE") {
+          $var(SetId) = 2;
+       }
+       sql_query("exec", "insert into dispatcher (setid, destination) select $var(SetId), \"$var(MediaUrl)\" where not exists(select * from dispatcher where destination = \"$var(MediaUrl)\")");
+       if($sqlrows(exec) > 0) {
+          xlog("L_WARNING", "reloading dispatcher table\n");
+          ds_reload();
+       }
    }
 }