diff --git a/server.js b/server.js
index 76b11ba..e78a2ce 100644
--- a/server.js
+++ b/server.js
@@ -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);