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

ЦИТК-1012 - Добавлены параметры протоколирования для брокеров MQTT/KAFKA, устранена ошибка подключения с использующимся sGroupId #12

Closed
Dollerok wants to merge 0 commits from Dollerok/P8-ExchangeService:master into master
pull from: Dollerok/P8-ExchangeService:master
merge into: CITKParus:master
Conversation 2 Commits - Files Changed - +141 -18
Dollerok commented 2025-12-08 15:50:58 +03:00
Member
Copy Link
No description provided.
Dollerok added 1 commit 2025-12-08 15:51:00 +03:00
Mim commented 2025-12-23 18:09:58 +03:00
Owner
Copy Link

Откомментировал в коде + сейчас понял, что ни для MQTT, ни для Kafka у нас нет в "models/obj_config.js" схем валидации, а должны быть. Прошу доработать в раках события ЦИТК-1012

Откомментировал в коде + сейчас понял, что ни для MQTT, ни для Kafka у нас нет в "models/obj_config.js" схем валидации, а должны быть. Прошу доработать в раках события ЦИТК-1012
Mim closed this pull request 2025-12-23 18:09:59 +03:00
Mim reviewed 2025-12-25 12:06:13 +03:00
core/mqtt_connector.js
@ -28,0 +37,4 @@
//Прослушиваем ошибки
client.on("error", e => {
//Если требуется выдавать ошибку
if (settings.sLogLevel === SLOG_ERROR) {
Mim commented 2025-12-23 18:07:21 +03:00
Owner
Copy Link

И на INFO (см. развернутый коммент ниже)

И на INFO (см. развернутый коммент ниже)
core/mqtt_connector.js
@ -67,2 +84,2 @@
//Выводим ошибку
logger.error(`Соединение с MQTT потеряно (${sBroker})`);
//Если требуется выдавать ошибку
if (settings.sLogLevel === SLOG_ERROR) {
Mim commented 2025-12-23 18:03:48 +03:00
Owner
Copy Link

Вот тут не совсем согласен - кажется, что это надо выдавать только для SLOG_INFO

Вот тут не совсем согласен - кажется, что это надо выдавать только для SLOG_INFO
core/mqtt_connector.js
@ -72,2 +92,2 @@
//Сообщим о восстановлении соединения
logger.info(`Соединение с MQTT восстановлено (${sBroker})`);
//Если требуется выдавать предупреждение
if ([SLOG_ERROR, SLOG_INFO].includes(settings.sLogLevel)) {
Mim commented 2025-12-23 18:06:31 +03:00
Owner
Copy Link

Аналогично и здесь - только для SLOG_INFO.
Я помню, мы обсуждали это, ты говорил о странностях с выдачей.
Но вот так - всё будет логично:
connect/online - только на уровне INFO (см. описание уровня в ПИ)
error - и на уровне INFO и на уровне ERROR

Аналогично и здесь - только для SLOG_INFO. Я помню, мы обсуждали это, ты говорил о странностях с выдачей. Но вот так - всё будет логично: connect/online - только на уровне INFO (см. описание уровня в ПИ) error - и на уровне INFO и на уровне ERROR
core/mqtt_connector.js
@ -74,0 +98,4 @@
//Прослушиваем ошибки
client.on("error", e => {
//Если требуется выдавать ошибку
if (settings.sLogLevel === SLOG_ERROR) {
Mim commented 2025-12-23 18:06:57 +03:00
Owner
Copy Link

и на INFO (см. развернутый коммент выше)

и на INFO (см. развернутый коммент выше)

Pull request closed

Please reopen this pull request to perform a merge.
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
No items
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
Dollerok GennadiyGA Mim Selivanov davay-popozhe juliapulia zzzboa
No Assignees
2 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: CITKParus/P8-ExchangeService#12
No description provided.
Delete Branch "Dollerok/P8-ExchangeService:master"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?