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