From 36e8adc3c252db03497c3790b736e90df022a9d4 Mon Sep 17 00:00:00 2001
From: boa604 <fukilya@gmail.com>
Date: Fri, 29 May 2026 13:24:44 +0300
Subject: [PATCH] =?UTF-8?q?=D0=A6=D0=98=D0=A2=D0=9A-1030.=20=D0=A3=D0=BF?=
 =?UTF-8?q?=D1=80=D0=BE=D1=89=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=BE=D1=81=D1=82?=
 =?UTF-8?q?=D0=B0=D0=BD=D0=BE=D0=B2=20=D0=BE=D0=B1=D1=80=D0=B0=D0=B1=D0=BE?=
 =?UTF-8?q?=D1=82=D1=87=D0=B8=D0=BA=D0=B0=20=D0=B8=D1=81=D1=85=D0=BE=D0=B4?=
 =?UTF-8?q?=D1=8F=D1=89=D0=B8=D1=85=20=D1=81=D0=BE=D0=BE=D0=B1=D1=89=D0=B5?=
 =?UTF-8?q?=D0=BD=D0=B8=D0=B5=20=D0=B1=D0=B5=D0=B7=20=D0=BF=D0=BE=D0=B2?=
 =?UTF-8?q?=D1=82=D0=BE=D1=80=D0=BD=D0=BE=D0=B3=D0=BE=20=D0=B7=D0=B0=D0=B2?=
 =?UTF-8?q?=D0=B5=D1=80=D1=88=D0=B5=D0=BD=D0=B8=D1=8F=20=D0=B4=D0=BE=D1=87?=
 =?UTF-8?q?=D0=B5=D1=80=D0=BD=D0=B5=D0=B3=D0=BE=20=D0=BF=D1=80=D0=BE=D1=86?=
 =?UTF-8?q?=D0=B5=D1=81=D1=81=D0=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 core/out_queue.js | 32 ++++++--------------------------
 1 file changed, 6 insertions(+), 26 deletions(-)

diff --git a/core/out_queue.js b/core/out_queue.js
index ef4a042..66abf43 100644
--- a/core/out_queue.js
+++ b/core/out_queue.js
@@ -195,33 +195,13 @@ class OutQueue extends EventEmitter {
             if (prms.proc) this.clearWorkerTerminateTimeout(prms.proc);
             //Удаляем идентификатор позиции очереди из списка обрабатываемых
             this.rmInProgress({ nQueueId: prms.nQueueId });
-            //Завершаем процесс обработчика, если он ещё активен
-            let killRes = true;
-            let killErr = false;
-            if (prms.proc?.connected) {
-                try {
-                    killRes = prms.proc.kill();
-                } catch (e) {
-                    killRes = false;
-                    killErr = true;
-                    //Отразим в протоколе ошибку останова
-                    await this.logger.error(`Ошибка останова обработчика исходящего сообщения ${prms.nQueueId}: ${makeErrorText(e)}`, {
-                        nQueueId: prms.nQueueId
-                    });
-                }
-            }
+            //Отразим в протоколе завершение процесса обработчика
             if (prms.proc) {
-                if (!killRes && !killErr)
-                    await this.logger.error(`Процесс обработчика исходящего сообщения ${prms.nQueueId} не был успешно завершен`, {
-                        nQueueId: prms.nQueueId
-                    });
-                else if (killRes) {
-                    const terminateTimeoutFired = prms.proc.terminateTimeoutFired === true;
-                    const message = `Процесс обработчика исходящего сообщения ${prms.nQueueId} завершен${terminateTimeoutFired ? " (по таймауту)" : ""}`;
-                    const logData = { nQueueId: prms.nQueueId };
-                    if (terminateTimeoutFired) await this.logger.warn(message, logData);
-                    else await this.logger.info(message, logData);
-                }
+                const terminateTimeoutFired = prms.proc.terminateTimeoutFired === true;
+                const message = `Процесс обработчика исходящего сообщения ${prms.nQueueId} завершен${terminateTimeoutFired ? " (по таймауту)" : ""}`;
+                const logData = { nQueueId: prms.nQueueId };
+                if (terminateTimeoutFired) await this.logger.warn(message, logData);
+                else await this.logger.info(message, logData);
             }
             //Сбрасываем признак "В работе" позиции очереди
             await this.dbConn.setInProgress({