Module: kamailio Branch: master Commit: cc7adf798c1f533e77dfab94563d7995094aa4c5 URL: https://github.com/kamailio/kamailio/commit/cc7adf798c1f533e77dfab94563d7995...
Author: lazedo luis.azedo@factorlusitano.com Committer: lazedo luis.azedo@factorlusitano.com Date: 2017-04-14T16:58:48+01:00
kazoo: add time msg was received
---
Modified: src/modules/kazoo/defs.h Modified: src/modules/kazoo/kz_amqp.c
---
Diff: https://github.com/kamailio/kamailio/commit/cc7adf798c1f533e77dfab94563d7995... Patch: https://github.com/kamailio/kamailio/commit/cc7adf798c1f533e77dfab94563d7995...
---
diff --git a/src/modules/kazoo/defs.h b/src/modules/kazoo/defs.h index 6059f53..91877c8 100644 --- a/src/modules/kazoo/defs.h +++ b/src/modules/kazoo/defs.h @@ -30,6 +30,14 @@ #define DBK_DEFS_H_
#define BLF_MAX_DIALOGS 8 + +#define BLF_JSON_AMQP_RECEIVED "AMQP-Received" +#define BLF_JSON_AMQP_CONSUMER "AMQP-Consumer" +#define BLF_JSON_AMQP_PUBLISHED "AMQP-Published" +#define BLF_JSON_AMQP_SENT "AMQP-Sent" +#define BLF_JSON_AMQP_PIPE_IN "AMQP-Pipe-In" +#define BLF_JSON_AMQP_PIPE_OUT "AMQP-Pipe-Out" + #define BLF_JSON_PRES "Presentity" #define BLF_JSON_PRES_USER "Presentity-User" #define BLF_JSON_PRES_REALM "Presentity-Realm" diff --git a/src/modules/kazoo/kz_amqp.c b/src/modules/kazoo/kz_amqp.c index d759490..6657443 100644 --- a/src/modules/kazoo/kz_amqp.c +++ b/src/modules/kazoo/kz_amqp.c @@ -2897,6 +2897,7 @@ void kz_amqp_send_worker_event(kz_amqp_server_ptr server_ptr, amqp_envelope_t* e }
json_object_object_add(json_obj, BLF_JSON_BROKER_ZONE, json_object_new_string(server_ptr->zone->zone)); + json_object_object_add(json_obj, BLF_JSON_AMQP_RECEIVED, json_object_new_int(time(NULL)));
JObj = kz_json_get_object(json_obj, BLF_JSON_SERVERID);