|
|
@ -827,7 +827,7 @@ event_route[kazoo:mod-init] |
|
|
### |
|
|
### |
|
|
### |
|
|
### |
|
|
|
|
|
|
|
|
$var(payload) = '{ "exchange" : "dialoginfo" , "type" : "direct", "queue" : "BLF-QUEUE-MY_HOSTNAME", "routing" : "BLF-MY_HOSTNAME", "auto_delete" : 0, "durable" : 1, "no_ack" : 0, "wait_for_consumer_ack" : 1 }'; |
|
|
|
|
|
|
|
|
$var(payload) = '{ "exchange" : "dialoginfo" , "type" : "direct", "queue" : "BLF-QUEUE-MY_HOSTNAME", "routing" : "BLF-MY_HOSTNAME", "queue-def" : {"durable" : 1}, "no_ack" : 0, "wait_for_consumer_ack" : 1 }'; |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
|
|
|
|
|
|
#!endif |
|
|
#!endif |
|
|
@ -835,28 +835,28 @@ event_route[kazoo:mod-init] |
|
|
#!ifdef MESSAGE_ROLE |
|
|
#!ifdef MESSAGE_ROLE |
|
|
|
|
|
|
|
|
$var(key) = "kamailio@MY_HOSTNAME"; |
|
|
$var(key) = "kamailio@MY_HOSTNAME"; |
|
|
$var(payload) = '{ "exchange" : "sms" , "type" : "topic", "queue" : "MSG-QUEUE-MY_HOSTNAME", "routing" : "message.route.' + $(var(key){kz.encode}) + '.*", "auto_delete" : 1, "durable" : 0, "no_ack" : 0, "wait_for_consumer_ack" : 1 }'; |
|
|
|
|
|
|
|
|
$var(payload) = '{ "exchange" : "sms" , "type" : "topic", "queue" : "MSG-QUEUE-MY_HOSTNAME", "routing" : "message.route.' + $(var(key){kz.encode}) + '.*", "queue-def" : {"auto_delete" : 1}, "no_ack" : 0, "wait_for_consumer_ack" : 1 }'; |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
|
|
|
|
|
|
#!endif |
|
|
#!endif |
|
|
|
|
|
|
|
|
#!ifdef DISPATCHER_ROLE |
|
|
#!ifdef DISPATCHER_ROLE |
|
|
|
|
|
|
|
|
$var(payload) = "{ 'exchange' : 'registrar' , 'type' : 'topic', 'queue' : 'MSG-FLUSH-MY_HOSTNAME', 'routing' : 'registration.flush.*', 'auto_delete' : 1, 'durable' : 0, 'no_ack' : 1, 'wait_for_consumer_ack' : 0 }"; |
|
|
|
|
|
|
|
|
$var(payload) = "{ 'exchange' : 'registrar' , 'type' : 'topic', 'queue' : 'MSG-FLUSH-MY_HOSTNAME', 'routing' : 'registration.flush.*', 'queue-def' : {'auto_delete' : 1}, 'no_ack' : 1, 'wait_for_consumer_ack' : 0 }"; |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
|
|
|
|
|
|
#!endif |
|
|
#!endif |
|
|
|
|
|
|
|
|
#!ifdef REGISTRAR_SYNC_ROLE |
|
|
#!ifdef REGISTRAR_SYNC_ROLE |
|
|
|
|
|
|
|
|
$var(payload) = "{ 'exchange' : 'registrar' , 'type' : 'topic', 'queue' : 'REGISTRAR-SYNC-QUEUE-MY_HOSTNAME', 'routing' : 'registration.sync', 'auto_delete' : 1, 'durable' : 0, 'no_ack' : 1, 'wait_for_consumer_ack' : 0 }"; |
|
|
|
|
|
|
|
|
$var(payload) = "{ 'exchange' : 'registrar' , 'type' : 'topic', 'queue' : 'REGISTRAR-SYNC-QUEUE-MY_HOSTNAME', 'routing' : 'registration.sync', 'queue-def' : {'auto_delete' : 1}, 'no_ack' : 1, 'wait_for_consumer_ack' : 0 }"; |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
|
|
|
|
|
|
#!endif |
|
|
#!endif |
|
|
|
|
|
|
|
|
#!ifdef PRESENCE_SYNC_ROLE |
|
|
#!ifdef PRESENCE_SYNC_ROLE |
|
|
|
|
|
|
|
|
$var(payload) = "{ 'exchange' : 'presence' , 'type' : 'topic', 'queue' : 'PRESENCE-QUEUE-MY_HOSTNAME', 'routing' : 'sync', 'auto_delete' : 1, 'durable' : 0, 'no_ack' : 1, 'wait_for_consumer_ack' : 0 }"; |
|
|
|
|
|
|
|
|
$var(payload) = "{ 'exchange' : 'presence' , 'type' : 'topic', 'queue' : 'PRESENCE-QUEUE-MY_HOSTNAME', 'routing' : 'sync', 'queue-def' : {'auto_delete' : 1}, 'no_ack' : 1, 'wait_for_consumer_ack' : 0 }"; |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
|
|
|
|
|
|
#!endif |
|
|
#!endif |
|
|
|