docker process path

server.js

@@ -7,6 +7,8 @@ const port = process.env.PORT || 3000;
 const KafkaConfig = require("./app/kconfig");
 const phpUnserialize = require('phpunserialize');
 
+const  assign_action = require('./app/assign_action');
+
 const kafka = new KafkaConfig();
 
 const app = express();
@@ -48,10 +50,7 @@ kafka.consume("NEW_OFFER_110022", (value) => {
       console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
       const obj = JSON.parse(value);
       console.log(  obj);
-      //  if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){
-      //     console.log("We need contact people that did this job: ", obj.depend_uid);
-      //
-      //  }
+      assign_action.processLinedJobs(ojb);
    } catch (exceptionVar) {
       console.log(" Error ", exceptionVar.message);
    }