new offer path

2024-08-25 11:07:28 -04:00
parent c5c67a841e
commit fcd75e230d
1 changed files with 4 additions and 2 deletions
@@ -36,9 +36,11 @@ routes(app);

 kafka.consume("NEW_OFFER_110011", (value) => {
   try {
-      console.log("Receive NEW_OFFER_110011 message xxxx: ", value);
      const obj = JSON.parse(value);
-      console.log(  obj);
+      console.log( "**Receive NEW_OFFER_110011 message : ", obj);
+      console.log("START -----------------------------------------");
+      assign_action.processLinedJobs(ojb);
+      console.log("END   -----------------------------------------");

   } catch (exceptionVar) {
      console.log(" Error ", exceptionVar.message);