فهرست منبع

kazoo: add time msg was received

lazedo 8 سال پیش
والد
کامیت
b78a90d4f1
2فایلهای تغییر یافته به همراه9 افزوده شده و 0 حذف شده
  1. 8 0
      src/modules/kazoo/defs.h
  2. 1 0
      src/modules/kazoo/kz_amqp.c

+ 8 - 0
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"

+ 1 - 0
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);