CITKParus/P8-ExchangeService
9
0
Fork 2
Code Issues Pull Requests Projects Releases 4 Wiki Activity

ЦИТК-1030. Переимование параметра "Таймаут параллельного процесса обработки исходящего сообщения" файла конфигурации.

Browse Source
This commit is contained in:
boa604 2026-05-26 12:45:53 +03:00
parent af995d2765
commit 45c0d42bcb
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
config.js
View File

@ -58,7 +58,7 @@ let outGoing = {
//Глобальный адрес прокси-сервера //Глобальный адрес прокси-сервера
sProxy: null, sProxy: null,
//Таймаут параллельного процесса обработки исходящего сообщения (мс, если задан атрибут "nTimeoutWorker" функции сервиса обмена - игнорируется, 0 - не применять) //Таймаут параллельного процесса обработки исходящего сообщения (мс, если задан атрибут "nTimeoutWorker" функции сервиса обмена - игнорируется, 0 - не применять)
nTimeoutWorker: 0 nWorkerTimeout: 0
}; };
//Параметры обработки очереди входящих сообщений //Параметры обработки очереди входящих сообщений

2
core/out_queue.js
View File

@ -182,7 +182,7 @@ class OutQueue extends EventEmitter {
//Определение таймаута параллельного процесса обработчика //Определение таймаута параллельного процесса обработчика
resolveWorkerTimeoutMs(serviceFn) { resolveWorkerTimeoutMs(serviceFn) {
if (serviceFn?.nTimeoutWorker > 0) return serviceFn.nTimeoutWorker; 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; return 0;
} }
//Останов обработчика //Останов обработчика

2
models/obj_config.js
View File

@ -298,7 +298,7 @@ const outGoing = new Schema({
} }
}, },
//Таймаут параллельного процесса обработки исходящего сообщения (мс) //Таймаут параллельного процесса обработки исходящего сообщения (мс)
nTimeoutWorker: { nWorkerTimeout: {
type: Number, type: Number,
required: false, required: false,
use: { validateTimeoutWorkerOutGoing }, use: { validateTimeoutWorkerOutGoing },