From ffb12c85503b041855a044c07ba867975de7cf29 Mon Sep 17 00:00:00 2001
From: Dollerino <dollerok101@gmail.com>
Date: Thu, 26 Sep 2024 14:44:52 +0300
Subject: [PATCH] =?UTF-8?q?=D0=A6=D0=98=D0=A2=D0=9A-901=20(=D0=94=D0=BE?=
 =?UTF-8?q?=D0=B1=D0=B0=D0=B2=D0=BB=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=BF=D0=BE?=
 =?UTF-8?q?=D0=B4=D0=B4=D0=B5=D1=80=D0=B6=D0=BA=D0=B8=20=D0=BF=D1=80=D0=BE?=
 =?UTF-8?q?=D1=82=D0=BE=D0=BA=D0=BE=D0=BB=D0=BE=D0=B2=20MQTT=20=D0=B8=20KA?=
 =?UTF-8?q?FKA)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 core/in_queue.js       | 10 +++++-----
 core/mqtt_connector.js |  2 +-
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/core/in_queue.js b/core/in_queue.js
index 6053e20..eb63e79 100644
--- a/core/in_queue.js
+++ b/core/in_queue.js
@@ -705,15 +705,15 @@ class InQueue extends EventEmitter {
     }
 
     //Закрытие подключений
-    async stopConnections() {
+    stopConnections() {
         //Если у нас есть соединения с MQTT
         if (this.mqttConnections.length !== 0) {
             //Закрываем их
             for (let connection of this.mqttConnections) {
                 try {
-                    await connection.end();
+                    connection.end();
                 } catch (e) {
-                    await this.logger.error(`Ошибка завершения MQTT подключения: ${makeErrorText(e)}`);
+                    this.logger.error(`Ошибка завершения MQTT подключения: ${makeErrorText(e)}`);
                 }
             }
         }
@@ -722,9 +722,9 @@ class InQueue extends EventEmitter {
             //Закрываем их
             for (let connection of this.kafkaConnections) {
                 try {
-                    await connection.disconnect();
+                    connection.disconnect();
                 } catch (e) {
-                    await this.logger.error(`Ошибка завершения Kafka подключения: ${makeErrorText(e)}`);
+                    this.logger.error(`Ошибка завершения Kafka подключения: ${makeErrorText(e)}`);
                 }
             }
         }
diff --git a/core/mqtt_connector.js b/core/mqtt_connector.js
index 428956c..e0af9e1 100644
--- a/core/mqtt_connector.js
+++ b/core/mqtt_connector.js
@@ -68,7 +68,7 @@ const subscribeMQTT = async ({ settings, service, processMessage, logger }) => {
             logger.error(`Соединение с MQTT потеряно (${sBroker})`);
         });
         //Прослушиваем восстановление соединения
-        client.on("reconnect", () => {
+        client.on("connect", () => {
             //Сообщим о восстановлении соединения
             logger.info(`Соединение с MQTT восстановлено (${sBroker})`);
         });