Add more event

server.js

@@ -32,17 +32,60 @@ routes(app);
 
 //eventInterest
 
+kafka.consume("NEW_OFFER_110011", (value) => {
+   try {
+      console.log("Receive NEW_OFFER_110011 message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
+
+   } catch (exceptionVar) {
+      console.log(" Error ", exceptionVar.message);
+   }
+});
+
 kafka.consume("NEW_OFFER_110022", (value) => {
    try {
       console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
       const obj = JSON.parse(value);
-      //var obj = phpUnserialize(value);
+      console.log(  obj);
-    // var obj = JSON.stringify(value);
+      //  if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){
-     console.log(  obj);
+      //     console.log("We need contact people that did this job: ", obj.depend_uid);
-     //  if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){
+      //
-     //     console.log("We need contact people that did this job: ", obj.depend_uid);
+      //  }
-     //
+   } catch (exceptionVar) {
-     //  }
+      console.log(" Error ", exceptionVar.message);
+   }
+});
+
+kafka.consume("NEW_OFFER_110033", (value) => {
+   try {
+      console.log("Receive NEW_OFFER_110033 message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
+
+   } catch (exceptionVar) {
+      console.log(" Error ", exceptionVar.message);
+   }
+});
+
+
+kafka.consume("NEW_OFFER_110055", (value) => {
+   try {
+      console.log("Receive NEW_OFFER_110055 message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
+
+   } catch (exceptionVar) {
+      console.log(" Error ", exceptionVar.message);
+   }
+});
+
+kafka.consume("SENDMONEY_RECEIVED", (value) => {
+   try {
+      console.log("Receive SENDMONEY_RECEIVED message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
+
    } catch (exceptionVar) {
       console.log(" Error ", exceptionVar.message);
    }
@@ -51,6 +94,8 @@ kafka.consume("NEW_OFFER_110022", (value) => {
 kafka.consume("INTEREST_MSG", (value) => {
    try {
       console.log("Receive INTEREST_MSG message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
       // var obj = phpUnserialize(value);
       // console.log(obj);
 
@@ -62,7 +107,8 @@ kafka.consume("INTEREST_MSG", (value) => {
 kafka.consume("FLUTTER_PAYMENT_RECEIVED", (value) => {
    try {
       console.log("Receive FLUTTER_PAYMENT_RECEIVED message xxxx: ", value);
-      var obj = phpUnserialize(value);
+      // var obj = phpUnserialize(value);
+      const obj = JSON.parse(value);
       console.log(obj);
       console.log("Receive message yyyy: ", obj.txRef);
    } catch (exceptionVar) {
@@ -71,8 +117,6 @@ kafka.consume("FLUTTER_PAYMENT_RECEIVED", (value) => {
 });
 
 
-
-
 app.listen(port, "0.0.0.0", function() {
    logger.info('***** Server started on port: ' + port + ' *****');
 });