kazoo: add time msg was received

kamailio · Apr 14, 2017 · cc7adf7 · cc7adf7
1 parent c86b882
commit cc7adf7
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git 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
@@ -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);