[sr-dev] git:master:cc7adf79: kazoo: add time msg was received

[lazedo]

Module: kamailio
Branch: master
Commit: cc7adf798c1f533e77dfab94563d7995094aa4c5
URL: https://github.com/kamailio/kamailio/commit/cc7adf798c1f533e77dfab94563d7995094aa4c5

Author: lazedo <luis.azedo at factorlusitano.com>
Committer: lazedo <luis.azedo at 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/cc7adf798c1f533e77dfab94563d7995094aa4c5.diff
Patch: https://github.com/kamailio/kamailio/commit/cc7adf798c1f533e77dfab94563d7995094aa4c5.patch

---

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