diff --git a/server.js b/server.js index e78a2ce..f4cc1d2 100644 --- a/server.js +++ b/server.js @@ -39,7 +39,7 @@ kafka.consume("NEW_OFFER_110011", (value) => { const obj = JSON.parse(value); console.log( "**Receive NEW_OFFER_110011 message : ", obj); console.log("START -----------------------------------------"); - assign_action.processLinedJobs(ojb); + assign_action.processLinedJobs(obj); console.log("END -----------------------------------------"); } catch (exceptionVar) { @@ -53,7 +53,7 @@ kafka.consume("NEW_OFFER_110022", (value) => { const obj = JSON.parse(value); console.log( "**Receive NEW_OFFER_110022 message : ", obj); console.log("START -----------------------------------------"); - assign_action.processLinedJobs(ojb); + assign_action.processLinedJobs(obj); console.log("END -----------------------------------------"); } catch (exceptionVar) { console.log(" Error ", exceptionVar.message);