CITKParus/P8-ExchangeService
7
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

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

Merged
Mim merged 4 commits from Dollerok/P8-ExchangeService:master into master 2024-09-25 16:20:34 +03:00
Conversation 0 Commits 4 Files Changed 13 -3
2 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 3128ed0492 - Show all commits

2
core/in_queue.js
View File

@ -556,14 +556,12 @@ class InQueue extends EventEmitter {
options = { options = {
method: fn.sFnPrmsType method: fn.sFnPrmsType
}; };
console.log("Кладём в очередь");
//Кладём сообщение в очередь //Кладём сообщение в очередь
q = await this.dbConn.putQueue({ q = await this.dbConn.putQueue({
nServiceFnId: fn.nId, nServiceFnId: fn.nId,
sOptions: buildOptionsXML({ options }), sOptions: buildOptionsXML({ options }),
blMsg blMsg
}); });
console.log("Продолжаем");
//Скажем что пришло новое входящее сообщение //Скажем что пришло новое входящее сообщение
await this.logger.info( await this.logger.info(
`Новое входящее MQTT-сообщение для функции ${fn.sCode} (${buildURL({ `Новое входящее MQTT-сообщение для функции ${fn.sCode} (${buildURL({

1
core/mqtt_connector.js
View File

@ -59,7 +59,6 @@ const subscribeMQTT = async ({ connectionPrms, service, processMQTTMessage, logg
//Прослушиваем сообщения //Прослушиваем сообщения
client.on("message", (topic, message) => { client.on("message", (topic, message) => {
console.log("message");
//Обрабатываем сообщение //Обрабатываем сообщение
processMQTTMessage({ message, service, fn: _.find(service.functions, { sFnURL: topic }) }); processMQTTMessage({ message, service, fn: _.find(service.functions, { sFnURL: topic }) });
}); });