[sr-dev] git:master:2b1e8db2: kazoo: log invalid json

[lazedo]

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

Author: lazedo <luis.azedo at factorlusitano.com>
Committer: lazedo <luis.azedo at factorlusitano.com>
Date: 2016-02-26T15:38:50Z

kazoo: log invalid json

---

Modified: modules/kazoo/kz_amqp.c

---

Diff:  https://github.com/kamailio/kamailio/commit/2b1e8db2838b7efc50b21ac66d6ef4494e96ddec.diff
Patch: https://github.com/kamailio/kamailio/commit/2b1e8db2838b7efc50b21ac66d6ef4494e96ddec.patch

---

diff --git a/modules/kazoo/kz_amqp.c b/modules/kazoo/kz_amqp.c
index 0557a71..e4c0779 100644
--- a/modules/kazoo/kz_amqp.c
+++ b/modules/kazoo/kz_amqp.c
@@ -1855,8 +1855,10 @@ int kz_amqp_send_ex(kz_amqp_server_ptr srv, kz_amqp_cmd_ptr cmd, kz_amqp_channel
     payload = amqp_bytes_malloc_dup(amqp_cstring_bytes(cmd->payload));
 
     json_obj = kz_json_parse(cmd->payload);
-    if (json_obj == NULL)
-    	goto error;
+    if (json_obj == NULL) {
+	    LM_ERR("error parsing json when publishing %s\n", cmd->payload);
+	    goto error;
+    }
 
     if(kz_json_get_object(json_obj, BLF_JSON_SERVERID) == NULL) {
         json_object_object_add(json_obj, BLF_JSON_SERVERID, json_object_new_string((char*)srv->channels[idx].targeted->routing_key.bytes));
@@ -2560,13 +2562,13 @@ void kz_amqp_send_worker_event(int _kz_server_id, amqp_envelope_t* envelope, kz_
     str* message_id = NULL;
     int idx = envelope->channel-1;
 
-	json_obj_ptr json_obj = kz_json_parse((char*)envelope->message.body.bytes);
+    json_obj_ptr json_obj = kz_json_parse((char*)envelope->message.body.bytes);
     if (json_obj == NULL) {
     	LM_ERR("error parsing json body\n");
     	return;
     }
 
-	json_object* JObj = kz_json_get_object(json_obj, BLF_JSON_SERVERID);
+    json_object* JObj = kz_json_get_object(json_obj, BLF_JSON_SERVERID);
     if(JObj != NULL) {
         const char* _kz_server_id_str = json_object_get_string(JObj);
         sprintf(buffer, "consumer://%d/%s", _kz_server_id, _kz_server_id_str);