From afeae085e7b2ea043bc9b8f38f93e961c2eb80f9 Mon Sep 17 00:00:00 2001 From: rakeshSgr Date: Fri, 4 Feb 2022 11:07:07 +0530 Subject: [PATCH] kafka changes --- module/observationSubmissions/helper.js | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/module/observationSubmissions/helper.js b/module/observationSubmissions/helper.js index 908e90d6..6a99e32e 100644 --- a/module/observationSubmissions/helper.js +++ b/module/observationSubmissions/helper.js @@ -130,7 +130,7 @@ module.exports = class ObservationSubmissionsHelper { console.log("BEFORE CALLING pushObservationSubmissionToKafka method "); const kafkaMessage = await kafkaClient.pushObservationSubmissionToKafka(observationSubmissionsDocument); - console.log("AFTER CALLING pushObservationSubmissionToKafka method ",kafkaMessage); + console.log("AFTER CALLING pushObservationSubmissionToKafka method ",JSON.stringify(kafkaMessage)); if(kafkaMessage.status != "success") { let errorObject = { @@ -146,7 +146,7 @@ module.exports = class ObservationSubmissionsHelper { } catch (error) { - console.log("pushObservationSubmissionForReporting() catch block",error); + console.log("pushObservationSubmissionForReporting() catch block",JSON.stringify(error)); return reject({ success: false, message: error.message, @@ -355,7 +355,7 @@ module.exports = class ObservationSubmissionsHelper { } catch (error) { - console.log("rateSubmissionById() catch block",error); + console.log("rateSubmissionById() catch block",JSON.stringify(error)); emailClient.pushMailToEmailService(emailRecipients,messageConstants.apiResponses.OBSERVATION_AUTO_RATING_FAILED+" - "+submissionId,error.message); return reject(error);