From 3128ed04923b90243cb6d61495c61d5c1fc37bfd Mon Sep 17 00:00:00 2001
From: Dollerino <dollerok101@gmail.com>
Date: Thu, 19 Sep 2024 15:19:28 +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       | 2 --
 core/mqtt_connector.js | 1 -
 2 files changed, 3 deletions(-)

diff --git a/core/in_queue.js b/core/in_queue.js
index 1237e04..316ecc3 100644
--- a/core/in_queue.js
+++ b/core/in_queue.js
@@ -556,14 +556,12 @@ class InQueue extends EventEmitter {
             options = {
                 method: fn.sFnPrmsType
             };
-            console.log("Кладём в очередь");
             //Кладём сообщение в очередь
             q = await this.dbConn.putQueue({
                 nServiceFnId: fn.nId,
                 sOptions: buildOptionsXML({ options }),
                 blMsg
             });
-            console.log("Продолжаем");
             //Скажем что пришло новое входящее сообщение
             await this.logger.info(
                 `Новое входящее MQTT-сообщение для функции ${fn.sCode} (${buildURL({
diff --git a/core/mqtt_connector.js b/core/mqtt_connector.js
index 48fcbc6..90c929a 100644
--- a/core/mqtt_connector.js
+++ b/core/mqtt_connector.js
@@ -59,7 +59,6 @@ const subscribeMQTT = async ({ connectionPrms, service, processMQTTMessage, logg
 
         //Прослушиваем сообщения
         client.on("message", (topic, message) => {
-            console.log("message");
             //Обрабатываем сообщение
             processMQTTMessage({ message, service, fn: _.find(service.functions, { sFnURL: topic }) });
         });