notify callback fix

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");
 }