From 45c0d42bcbdfd95fe88fdda73954602826673e3d Mon Sep 17 00:00:00 2001 From: boa604 Date: Tue, 26 May 2026 12:45:53 +0300 Subject: [PATCH] =?UTF-8?q?=D0=A6=D0=98=D0=A2=D0=9A-1030.=20=D0=9F=D0=B5?= =?UTF-8?q?=D1=80=D0=B5=D0=B8=D0=BC=D0=BE=D0=B2=D0=B0=D0=BD=D0=B8=D0=B5=20?= =?UTF-8?q?=D0=BF=D0=B0=D1=80=D0=B0=D0=BC=D0=B5=D1=82=D1=80=D0=B0=20"?= =?UTF-8?q?=D0=A2=D0=B0=D0=B9=D0=BC=D0=B0=D1=83=D1=82=20=D0=BF=D0=B0=D1=80?= =?UTF-8?q?=D0=B0=D0=BB=D0=BB=D0=B5=D0=BB=D1=8C=D0=BD=D0=BE=D0=B3=D0=BE=20?= =?UTF-8?q?=D0=BF=D1=80=D0=BE=D1=86=D0=B5=D1=81=D1=81=D0=B0=20=D0=BE=D0=B1?= =?UTF-8?q?=D1=80=D0=B0=D0=B1=D0=BE=D1=82=D0=BA=D0=B8=20=D0=B8=D1=81=D1=85?= =?UTF-8?q?=D0=BE=D0=B4=D1=8F=D1=89=D0=B5=D0=B3=D0=BE=20=D1=81=D0=BE=D0=BE?= =?UTF-8?q?=D0=B1=D1=89=D0=B5=D0=BD=D0=B8=D1=8F"=20=D1=84=D0=B0=D0=B9?= =?UTF-8?q?=D0=BB=D0=B0=20=D0=BA=D0=BE=D0=BD=D1=84=D0=B8=D0=B3=D1=83=D1=80?= =?UTF-8?q?=D0=B0=D1=86=D0=B8=D0=B8.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- config.js | 2 +- core/out_queue.js | 2 +- models/obj_config.js | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/config.js b/config.js index be2fb74..c02dc88 100644 --- a/config.js +++ b/config.js @@ -58,7 +58,7 @@ let outGoing = { //Глобальный адрес прокси-сервера sProxy: null, //Таймаут параллельного процесса обработки исходящего сообщения (мс, если задан атрибут "nTimeoutWorker" функции сервиса обмена - игнорируется, 0 - не применять) - nTimeoutWorker: 0 + nWorkerTimeout: 0 }; //Параметры обработки очереди входящих сообщений diff --git a/core/out_queue.js b/core/out_queue.js index 380474b..ef4a042 100644 --- a/core/out_queue.js +++ b/core/out_queue.js @@ -182,7 +182,7 @@ class OutQueue extends EventEmitter { //Определение таймаута параллельного процесса обработчика resolveWorkerTimeoutMs(serviceFn) { if (serviceFn?.nTimeoutWorker > 0) return serviceFn.nTimeoutWorker; - if (this.outGoing.nTimeoutWorker > 0) return this.outGoing.nTimeoutWorker; + if (this.outGoing.nWorkerTimeout > 0) return this.outGoing.nWorkerTimeout; return 0; } //Останов обработчика diff --git a/models/obj_config.js b/models/obj_config.js index b18a3b1..4b0a21d 100644 --- a/models/obj_config.js +++ b/models/obj_config.js @@ -298,7 +298,7 @@ const outGoing = new Schema({ } }, //Таймаут параллельного процесса обработки исходящего сообщения (мс) - nTimeoutWorker: { + nWorkerTimeout: { type: Number, required: false, use: { validateTimeoutWorkerOutGoing },