tj

brg-queue-center/app/base/db/consumer.base.js

@@ -22,6 +22,7 @@ class ConsumerBase {
       }
       }
       var self = this;
       var self = this;
       this.duplicateInstance.brpop(queuedName, 3600, async function (err, repl) {
       this.duplicateInstance.brpop(queuedName, 3600, async function (err, repl) {
+        console.log(JSON.stringify(repl), "..........repl..............");
         if (err) {
         if (err) {
           return new Error('doConsumer brpop error :' + err);
           return new Error('doConsumer brpop error :' + err);
         }
         }

brg-queue-center/app/base/utils/redisClient.js

@@ -87,7 +87,7 @@ class RedisClient {
       if (err) {
       if (err) {
         return new Error("lpush message error :" + err + "，queuedName：" + queuedName + "，messageBody：" + messageBody);
         return new Error("lpush message error :" + err + "，queuedName：" + queuedName + "，messageBody：" + messageBody);
       } else {
       } else {
-        console.log("lpush message success");
+        console.log("lpush message success....");
       }
       }
     });
     });
   }
   }

brg-queue-center/app/config/settings.js

@@ -10,8 +10,8 @@ var ENVINPUT = {
   REDIS_DB: process.env.QUEUE_REDIS_DB,
   REDIS_DB: process.env.QUEUE_REDIS_DB,
   DB_NAME: process.env.QUEUE_DB_NAME,
   DB_NAME: process.env.QUEUE_DB_NAME,
   APP_ENV: process.env.APP_ENV ? process.env.APP_ENV : "test",//运行环境
   APP_ENV: process.env.APP_ENV ? process.env.APP_ENV : "test",//运行环境
-  CONSUMER_NAME: process.env.CONSUMER_NAME || "publicServiceAllocation.publicConsumer",//消费者名称
-  QUEUED_NAME: process.env.QUEUED_NAME || "SYTXPUBLIC-MSGQ",//队列名称，FAIL-失败队列（队列和失败队列一对存在进行部署）
+  CONSUMER_NAME: process.env.CONSUMER_NAME || "publicLogs.publicLogsConsumer",//消费者名称
+  QUEUED_NAME: process.env.QUEUED_NAME || "LOGS-SYTXPUBLIC-MSGQ",//队列名称，FAIL-失败队列（队列和失败队列一对存在进行部署）
 };
 };
 var settings = {
 var settings = {
   env: ENVINPUT.APP_ENV,
   env: ENVINPUT.APP_ENV,