obj not defined
This commit is contained in:
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user