tj

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

@@ -21,7 +21,7 @@ class ConsumerBase {
         counter = 1;
       }
       var self = this;
-      this.duplicateInstance.brpop(queuedName, 10800, async function (err, repl) {
+      this.duplicateInstance.brpop(queuedName, 3600, async function (err, repl) {
         if (err) {
           return new Error('doConsumer brpop error :' + err);
         }

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

@@ -18,7 +18,7 @@ class PublicConsumer extends ConsumerBase {
     }
     var execResult = await this.execPostByTimeOut(params, actionBody.pushUrl);
     var tmpBody = {
-      "opTitle": "队列推送数据记录",// N 操作的业务标题
+      "opTitle": "队列推送数据记录，推送地址：" + actionBody.pushUrl,// N 操作的业务标题
       "identifyCode": actionBody.identifyCode || "",// Y 操作的业务标识
       "indexName": "push-logs",// Y es索引值，同一个项目用一个值
       "messageBody": params,

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

@@ -43,6 +43,7 @@ var settings = {
         password: ENVINPUT.DB_PWD,
         config: {
           host: ENVINPUT.DB_HOST,
+          port: ENVINPUT.DB_PORT,
           dialect: 'mysql',
           operatorsAliases: false,
           pool: {
@@ -55,10 +56,10 @@ var settings = {
           },
           timezone: '+08:00',
           debug: false,
-          dialectOptions: {
-            requestTimeout: 999999,
-            // instanceName:'DEV'
-          }  //设置MSSQL超时时间
+          // dialectOptions: {
+          //   requestTimeout: 999999,
+          //   // instanceName:'DEV'
+          // }  //设置MSSQL超时时间
         },
       };
     }