ЦИТК-901 (Добавление поддержки протоколов MQTT и KAFKA)

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)}`);
                 }
             }
         }

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})`);
         });