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