From 0a6eb5bd8d9fc85d16f4c7aa5840a0298739b274 Mon Sep 17 00:00:00 2001 From: lazedo Date: Wed, 29 Apr 2015 22:09:14 +0100 Subject: [PATCH] KAZOO-3593 user Server-ID instead of Queue --- kamailio/registrar-sync-role.cfg | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/kamailio/registrar-sync-role.cfg b/kamailio/registrar-sync-role.cfg index 49717ef..de3b04b 100644 --- a/kamailio/registrar-sync-role.cfg +++ b/kamailio/registrar-sync-role.cfg @@ -9,7 +9,8 @@ modparam("sqlops","sqlcon", KAZOO_SQLOPS_DB_URL) event_route[kazoo:consumer-event-directory-reg-sync] { - xlog("L_INFO", "received registrar SYNC $kzE"); + $var(Server) = $(kzE{kz.json,Server-ID}); + xlog("L_INFO", "received registrar sync from $var(Server) : $kzE"); if (sql_xquery("cb", "location", "ra") == 1) { @@ -20,7 +21,7 @@ event_route[kazoo:consumer-event-directory-reg-sync] xlog("L_INFO", "[id, username, domain] = [$xavp(ra=>id), $xavp(ra=>username), $xavp(ra=>domain)]"); $var(Expires) = $xavp(ra=>expires) - $TS; $var(amqp_payload_request) = '{"Event-Category" : "directory", "Event-Name" : "reg_success", "Status" : "Success", "Event-Timestamp" : $TS, "Expires" : $(var(Expires){s.int}), "First-Registration" : false, "Contact" : "$(xavp(ra=>contact){s.escape.common})", "Call-ID" : "$xavp(ra=>callid)", "Realm" : "$xavp(ra=>domain)", "Username" : "$xavp(ra=>username)", "From-User" : "$xavp(ra=>username)", "From-Host" : "$xavp(ra=>domain)", "To-User" : "$xavp(ra=>username)", "To-Host" : "$xavp(ra=>domain)", "User-Agent" : "$(xavp(ra=>user_agent){s.escape.common})" , "Custom-Channel-Vars" : $xavp(ulattrs=>custom_channel_vars), "Proxy-Path" : "sip:$(xavp(ra=>socket){s.substr,4,0})" }'; - kazoo_publish("targeted", "$(kzE{kz.json,Queue})", $var(amqp_payload_request)); + kazoo_publish("targeted", "$var(Server)", $var(amqp_payload_request)); } pv_unset("$xavp(ra)"); $var(runloop) = $var(runloop) + 1;