Module: kamailio Branch: master Commit: cc7adf798c1f533e77dfab94563d7995094aa4c5 URL: https://github.com/kamailio/kamailio/commit/cc7adf798c1f533e77dfab94563d799… Author: lazedo <luis.azedo(a)factorlusitano.com> Committer: lazedo <luis.azedo(a)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/cc7adf798c1f533e77dfab94563d799… Patch: https://github.com/kamailio/kamailio/commit/cc7adf798c1f533e77dfab94563d799… --- 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);