|
|
@ -121,7 +121,7 @@ route[PRESENCE_LOG_TIMER_ROUTE] |
|
|
|
|
|
|
|
|
route[PRESENCE_NOTIFY_AMQP] |
|
|
route[PRESENCE_NOTIFY_AMQP] |
|
|
{ |
|
|
{ |
|
|
$var(amqp_payload_request) = $_s({"Event-Category" : "presence", "Event-Name" : "notify", "Event-Package" : "$subs(event)", "Timestamp" : $TS, "Call-ID" : "$subs(callid)", "From" : "$fu", "To" : "$subs(to_user)@$subs(to_domain)", "Sent" : "$(TS{s.ftime,%Y-%m-%d %H:%M:%S})", "Body" : "Hostname : MY_HOSTNAME\r\nTimestamp : $(TS{s.ftime,%Y-%m-%d %H:%M:%S})\r\n$(mb{s.escape.common}{s.replace,\','}{s.replace,$$,})\r\nResponse\r\n$(notify_reply($mb){s.escape.common}{s.replace,\','}{s.replace,$$,})", "Sequence" : $cs, "Reply" : $notify_reply($rs) }); |
|
|
|
|
|
|
|
|
$var(amqp_payload_request) = $_s({"Event-Category" : "presence", "Event-Name" : "notify", "Event-Package" : "$subs(event)", "Timestamp" : $TS, "Call-ID" : "$subs(callid)", "From" : "$fu", "To" : "$subs(to_user)@$subs(to_domain)", "Sent" : "$(TS{s.ftime,%Y-%m-%d %H:%M:%S})", "Body" : "Hostname : MY_HOSTNAME\r\nTimestamp : $(TS{s.ftime,%Y-%m-%d %H:%M:%S})\r\n$(mb{s.escape.common}{s.replace,\','}{s.replace,$$,})\r\nResponse\r\n$(notify_reply($mb){s.escape.common}{s.replace,\','}{s.replace,$$,})","Remote-CSeq" : $subs(remote_cseq), "Local-CSeq" : $subs(local_cseq), "Sequence" : $cs, "Version" : $subs(version), "Reply" : $notify_reply($rs) }); |
|
|
$var(rk) = "notify." + $(subs(to_domain){kz.encode}) + "." + $(subs(to_user){kz.encode}); |
|
|
$var(rk) = "notify." + $(subs(to_domain){kz.encode}) + "." + $(subs(to_user){kz.encode}); |
|
|
kazoo_publish("omnipresence", "$var(rk)", $var(amqp_payload_request)); |
|
|
kazoo_publish("omnipresence", "$var(rk)", $var(amqp_payload_request)); |
|
|
xlog("L_INFO", "$ci|log|sent notify callback for event $subs(event) : $tu\n"); |
|
|
xlog("L_INFO", "$ci|log|sent notify callback for event $subs(event) : $tu\n"); |
|
|
|