optional REGISTRAR_CHECK_AMQP_AVAILABILITY

kamailio/registrar-role.cfg

@@ -20,6 +20,8 @@
 #!trydef REGISTRAR_FORCE_QUERY 0
 #!trydef REGISTRAR_FORCE_FAILOVER 0
 
+#!trydef REGISTRAR_CHECK_AMQP_AVAILABILITY 1
+
 ######## Generic Hash Table container in shared memory ########
 modparam("htable", "htable", "auth_cache=>size=16;autoexpire=7200;")
 
@@ -86,6 +88,8 @@ kazoo.registrar_query_timeout_ms = REGISTRAR_QUERY_TIMEOUT_MS descr "timeout wai
 
 kazoo.registrar_failover = REGISTRAR_FORCE_FAILOVER descr "force failover if 1"
 kazoo.registrar_force_query = REGISTRAR_FORCE_QUERY descr "force query if 1"
+kazoo.registrar_check_amqp_availability = REGISTRAR_CHECK_AMQP_AVAILABILITY descr "checks if amqp connection is available before querying registrar"
+
 
 ####### Registrar Logic ########
 route[HANDLE_REGISTER]
@@ -167,9 +171,11 @@ route[ATTEMPT_AUTHORIZATION]
         drop;
     }
 
-    if($xavp(amqpc=>default::MY_AMQP_ZONE) == 0) {
-        xlog("L_INFO", "$ci|log|register|no amqp connection available for default worker in zone MY_AMQP_ZONE\n");
-        t_drop();
+    if($sel(cfg_get.kazoo.registrar_check_amqp_availability) == 1) {   
+        if($xavp(amqpc=>default::MY_AMQP_ZONE) == 0) {
+            xlog("L_INFO", "$ci|log|register|no amqp connection available for default worker in zone MY_AMQP_ZONE\n");
+            t_drop();
+        }
     }
 
     if($sel(cfg_get.kazoo.registrar_failover) == 1) {