From 07304e2c69578045bdb934fce405107accd9a1f3 Mon Sep 17 00:00:00 2001 From: lazedo Date: Thu, 29 Oct 2015 13:37:01 +0000 Subject: [PATCH] notify callback fix --- kamailio/presence_notify_sync-role.cfg | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/kamailio/presence_notify_sync-role.cfg b/kamailio/presence_notify_sync-role.cfg index 270f531..fca78e0 100644 --- a/kamailio/presence_notify_sync-role.cfg +++ b/kamailio/presence_notify_sync-role.cfg @@ -15,14 +15,15 @@ route[PRESENCE_LOCAL_NOTIFY] onreply_route[PRESENCE_NOTIFY_REPLY] { $var(amqp_payload_request) = '{"Event-Category" : "presence", "Event-Name" : "notify", "Event-Package" : "$avp(notify_event)", "Call-ID" : "$ci", "From" : "$fu", "To" : "$tu", "Body" : "$(avp(notify_body){s.escape.common})", "Sequence" : $cs, "Reply" : $T_reply_code }'; - $var(rk) = "notify." + $td + "." + $tU; - kazoo_publish("dialoginfo_subs", "$var(rk)", $var(amqp_payload_request)); - xlog("L_INFO", "$ci|log|event $avp(notify_event)"); + $var(rk) = "notify." + $(td{kz.encode}) + "." + $(tU{kz.encode}); + kazoo_publish("omnipresence", "$var(rk)", $var(amqp_payload_request)); + xlog("L_INFO", "$ci|log|sent notify callback for event $avp(notify_event) : $tu"); } onreply_route[PRESENCE_NOTIFY_FAULT] { $var(amqp_payload_request) = '{"Event-Category" : "presence", "Event-Name" : "notify", "Event-Package" : "$avp(notify_event)", "Call-ID" : "$ci", "From" : "$fu", "To" : "$tu", "Body" : "$(avp(notify_body){s.escape.common})", "Sequence" : $cs, "Reply" : $T_reply_code }'; - $var(rk) = "notify." + $td + "." + $tU; - kazoo_publish("dialoginfo_subs", "$var(rk)", $var(amqp_payload_request)); + $var(rk) = "notify." + $(td{kz.encode}) + "." + $(tU{kz.encode}); + kazoo_publish("omnipresence", "$var(rk)", $var(amqp_payload_request)); + xlog("L_INFO", "$ci|log|sent notify callback error $T_reply_code for event $avp(notify_event) : $tu"); }