diff --git a/app/assign_action.js b/app/assign_action.js
index 76375a3..70b6ef6 100644
--- a/app/assign_action.js
+++ b/app/assign_action.js
@@ -1,18 +1,16 @@
 const db = require('../app/db')
 const logger = require('../app/logger');
-const redeem = require("../service/redeem");
-
 
 var assign_action ={
 
-    processLinedJobs(req) {
+    processLinedJobs(value) {
 
-        console.log("Receive NEW_OFFER_110022 message processLinedJobs ************************ : ", req);
+        console.log("Receive NEW_OFFER_110022 message processLinedJobs ************************ : ", revalueq);
         //  if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){
         //     console.log("We need contact people that did this job: ", obj.depend_uid);
         //
-        //  }
-},
+    //  }
+    },
 
 };
 
diff --git a/server.js b/server.js
index 702459a..76b11ba 100644
--- a/server.js
+++ b/server.js
@@ -47,10 +47,12 @@ kafka.consume("NEW_OFFER_110011", (value) => {
 
 kafka.consume("NEW_OFFER_110022", (value) => {
    try {
-      console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
+     // console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
       const obj = JSON.parse(value);
-      console.log(  obj);
+      console.log( "**Receive NEW_OFFER_110022 message : ", obj);
+      console.log("START -----------------------------------------");
       assign_action.processLinedJobs(ojb);
+      console.log("END   -----------------------------------------");
    } catch (exceptionVar) {
       console.log(" Error ", exceptionVar.message);
    }