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 },